30 #ifndef __ZMQ_DISH_HPP_INCLUDED__ 31 #define __ZMQ_DISH_HPP_INCLUDED__ 70 int xjoin (
const char *group_);
71 int xleave (
const char *group_);
106 int push_msg (
msg_t *msg_);
107 int pull_msg (
msg_t *msg_);
void xpipe_terminated(zmq::pipe_t *pipe_)
subscriptions_t subscriptions
void xread_activated(zmq::pipe_t *pipe_)
int xleave(const char *group_)
void xwrite_activated(zmq::pipe_t *pipe_)
void xhiccuped(pipe_t *pipe_)
int xrecv(zmq::msg_t *msg_)
int xsend(zmq::msg_t *msg_)
std::basic_string< unsigned char > blob_t
blob_t get_credential() const
const dish_t & operator=(const dish_t &)
void send_subscriptions(pipe_t *pipe_)
void xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_)
std::set< std::string > subscriptions_t
dish_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_)
int xjoin(const char *group_)