25 #ifndef AOSSL_ZMQ_INCLUDE_ZMQ_INTERFACE_H_ 26 #define AOSSL_ZMQ_INCLUDE_ZMQ_INTERFACE_H_ 30 const int REQ_RESP = 0;
31 const int PUB_SUB = 1;
41 virtual std::string
recv() = 0;
44 virtual char *
crecv() = 0;
47 virtual void send(
const char * msg,
int msg_size) = 0;
50 virtual void send(std::string msg) = 0;
53 virtual void subscribe(std::string filter) = 0;
65 virtual void connect(std::string conn_str) = 0;
68 virtual void send(
const char * msg,
int msg_size) = 0;
71 virtual void send(std::string msg) = 0;
74 virtual std::string
recv() = 0;
77 virtual char *
crecv() = 0;
80 virtual void subscribe(std::string filter) = 0;
92 virtual void bind(std::string conn_str) = 0;
95 virtual std::string
recv() = 0;
98 virtual char *
crecv() = 0;
101 virtual void send(
const char * msg,
int msg_size) = 0;
104 virtual void send(std::string msg) = 0;
107 virtual void subscribe(std::string filter) = 0;
109 #endif // AOSSL_ZMQ_INCLUDE_ZMQ_INTERFACE_H_ An Interface for ZMQIO.
Definition: zmq_interface.h:37
An Inbound ZMQ Manager.
Definition: zmq_interface.h:87
virtual char * crecv()=0
Recieve a message on the port.
virtual void subscribe(std::string filter)=0
Subscribe on a particular filter (only effective for Pub/Sub)
An Outbound ZMQ Manager.
Definition: zmq_interface.h:60
virtual void send(const char *msg, int msg_size)=0
Send a message on the port.
virtual std::string recv()=0
Recieve a message on the port.