detach() | ZmqMessage::Sink | [inline] |
dst() | ZmqMessage::Sink | [inline] |
flush() | ZmqMessage::Sink | |
incoming() const | ZmqMessage::Sink | [inline] |
is_dropping() const | ZmqMessage::Sink | [inline] |
is_queued() const | ZmqMessage::Sink | [inline] |
operator<<(const T &t) | ZmqMessage::Sink | |
operator<<(zmq::message_t &msg) | ZmqMessage::Sink | |
operator<<(MsgPtr msg) | ZmqMessage::Sink | [inline] |
operator<<(const RawMessage &m) | ZmqMessage::Sink | |
operator<<(Sink &(*f)(Sink &)) | ZmqMessage::Sink | [inline] |
options() const | ZmqMessage::Sink | [inline, protected] |
Outgoing(zmq::socket_t &dst, unsigned options) | ZmqMessage::Outgoing< RoutingPolicy > | [inline] |
Outgoing(OutOptions out_opts) | ZmqMessage::Outgoing< RoutingPolicy > | [inline, explicit] |
Outgoing(zmq::socket_t &dst, Incoming< InRoutingPolicy > &incoming, unsigned options) | ZmqMessage::Outgoing< RoutingPolicy > | [inline] |
Outgoing(OutOptions out_opts, Incoming< InRoutingPolicy > &incoming) | ZmqMessage::Outgoing< RoutingPolicy > | [inline] |
Outgoing(zmq::socket_t &dst, Multipart &incoming, unsigned options) | ZmqMessage::Outgoing< RoutingPolicy > | [inline] |
Outgoing(OutOptions out_opts, Multipart &incoming) | ZmqMessage::Outgoing< RoutingPolicy > | [inline] |
relay_from(zmq::socket_t &relay_src) | ZmqMessage::Sink | |
relay_from(zmq::socket_t &relay_src, OccupationAccumulator acc) | ZmqMessage::Sink | |
RoutingPolicyType typedef | ZmqMessage::Outgoing< RoutingPolicy > | |
send_incoming_messages(size_t idx_from=0, size_t idx_to=UINT_MAX) | ZmqMessage::Sink | |
send_incoming_messages(Multipart &multipart, bool copy, size_t idx_from=0, size_t idx_to=UINT_MAX) | ZmqMessage::Sink | |
send_one(zmq::message_t *msg, bool use_copy=false) | ZmqMessage::Sink | [protected] |
send_routing(MsgPtrVec *routing) | ZmqMessage::Outgoing< RoutingPolicy > | |
send_routing(MsgPtrVec *routing) | ZmqMessage::Outgoing< RoutingPolicy > | |
set_binary() | ZmqMessage::Sink | [inline] |
set_text() | ZmqMessage::Sink | [inline] |
Sink(zmq::socket_t &dst, unsigned options, Multipart *incoming=0) | ZmqMessage::Sink | [inline, protected] |
~Sink() | ZmqMessage::Sink | [virtual] |