4 #include "MessageZyre.hh"
7 #include "PollerZmq.hh"
8 #include "SocketZyre.hh"
19 class NodeManagerZyre;
31 void addSocket(std::shared_ptr<SocketZyre> socket);
32 std::vector<std::shared_ptr<SocketZyre>>
sockets()
const;
58 std::vector<std::shared_ptr<SocketZyre>>
mSockets{};
ZeroMQ implementation of salsa actor class.
std::string mJobInfoGroupName
JobInfo Group name.
void jobInfoGroupName(std::string n)
Sets JobInfo Group name.
void jobInfoClientUrl(std::string url)
Sets JobInfo client url.
int mJobCheckTimeout
Job check timeout.
void jobInfoBrokerUrl(std::string url)
Sets JobInfo broker url.
void addSocket(std::shared_ptr< SocketZyre > socket)
std::string mJobInfoClientUrl
JobInfo url for client (salsa-broker –out ...)
std::vector< std::shared_ptr< SocketZyre > > sockets() const
void submitClientUrl(std::string url)
Sets Submit client url.
virtual int init()
First function.
virtual int exec()
Main function.
std::string mSubmitClientUrl
Submit url for client.
std::string jobInfoClientUrl()
Returns JobInfo client url.
NodeZyre(std::string name="")
Construct Zyre node with provided name (and packetizer)
virtual int finish()
Last function.
NodeManagerZyre * mpNodeManager
Job manager.
std::string jobInfoBrokerUrl()
Returns JobInfo broker url.
zsock_t * socketExternal(int i)
Rerturns external socket.
std::string submitClientUrl()
Returns Submit client url.
std::string jobInfoGroupName()
Returns JobInfo Group name.
std::vector< std::shared_ptr< SocketZyre > > mSockets
List of zyre sockets.
void handleExternalZmq(zmsg_t *pMsg, zsock_t *pSocket)
virtual ~NodeZyre()
Destruct Zyre node.
std::string mJobInfoBrokerUrl
JobInfo broker url (salsa-broker –in ...)
std::vector< zsock_t * > mZmqSockets
List of zmq sockets.
std::string name() const
Returns node name.