|
|
| ZeroMQService (boost::shared_ptr< zmq::context_t > context) |
| |
|
void | set_cfg (const protobuf::ZeroMQServiceConfig &cfg) |
| |
|
void | merge_cfg (const protobuf::ZeroMQServiceConfig &cfg) |
| |
|
void | subscribe_all (int socket_id) |
| |
|
void | unsubscribe_all (int socket_id) |
| |
|
void | send (MarshallingScheme marshalling_scheme, const std::string &identifier, const std::string &body, int socket_id) |
| |
|
void | subscribe (MarshallingScheme marshalling_scheme, const std::string &identifier, int socket_id) |
| |
|
void | unsubscribe (MarshallingScheme marshalling_scheme, const std::string &identifier, int socket_id) |
| |
|
template<class C > |
| void | connect_inbox_slot (void(C::*mem_func)(MarshallingScheme, const std::string &, const std::string &, int), C *obj) |
| |
|
void | connect_inbox_slot (boost::function< void(MarshallingScheme marshalling_scheme, const std::string &identifier, const std::string &body, int socket_id)> slot) |
| |
|
bool | poll (long timeout=-1) |
| |
|
void | close_all () |
| |
|
ZeroMQSocket & | socket_from_id (int socket_id) |
| |
|
template<class C > |
| void | register_poll_item (const zmq::pollitem_t &item, void(C::*mem_func)(const void *, int, int), C *obj) |
| |
|
void | register_poll_item (const zmq::pollitem_t &item, boost::function< void(const void *data, int size, int message_part)> callback) |
| |
|
boost::shared_ptr< zmq::context_t > | zmq_context () |
| |
|
|
static std::string | glog_out_group () |
| |
|
static std::string | glog_in_group () |
| |
|
|
boost::signals2::signal< void(MarshallingScheme marshalling_scheme, const std::string &identifier, int socket_id)> | pre_send_hooks |
| |
|
boost::signals2::signal< void(MarshallingScheme marshalling_scheme, const std::string &identifier, int socket_id)> | pre_subscribe_hooks |
| |
|
boost::signals2::signal< void(MarshallingScheme marshalling_scheme, const std::string &identifier, int socket_id)> | post_send_hooks |
| |
|
boost::signals2::signal< void(MarshallingScheme marshalling_scheme, const std::string &identifier, int socket_id)> | post_subscribe_hooks |
| |
Definition at line 102 of file zeromq_service.h.
The documentation for this class was generated from the following files:
1.8.11
