3 #include "NodeManager.hh"
5 #include "PollerZmq.hh"
24 virtual Socket *
onEnter(std::string
self, std::string fromType,
Message * pMsg, std::vector<std::string> & out);
30 virtual void runTask(
TaskState * pTaskState, std::string wk, std::string upstream);
31 virtual bool sendWhisper(
Socket * pSocket, std::string to, std::vector<std::string> & vect);
virtual Socket * onEnter(std::string self, std::string fromType, Message *pMsg, std::vector< std::string > &out)
NodeManagerZyre(NodeZyre *pNodeZyre)
Base salsa TaskState class.
virtual Socket * onExit(std::string self, Message *pMsg, std::vector< std::string > &out)
NodeZyre * mpNodeZyre
Current zyre node.
virtual ~NodeManagerZyre()
Job * job(std::string uuid)
virtual bool sendWhisper(Socket *pSocket, std::string to, std::vector< std::string > &vect)
virtual Socket * onWhisper(std::string self, Message *pMsg, std::vector< std::string > &out)
virtual void resultTaskToExternal(Job *job, TaskInfo *task)
Handle return of task and send it to external client.
virtual void runTask(TaskState *pTaskState, std::string wk, std::string upstream)
Run task interface.
virtual bool handleTaskPool(void *pPool)
virtual void addTaskSlot()