libmoost
|
connect(const std::string &hostname, int port, boost::function< void(const boost::system::error_code &, const std::string &)> error_cb) | moost::mq::stomp_client | |
disconnect() | moost::mq::stomp_client | |
get_num_pending() const | moost::mq::stomp_client | |
get_num_processed() const | moost::mq::stomp_client | |
is_connected() const | moost::mq::stomp_client | |
is_online() const | moost::mq::stomp_client | |
m_impl | moost::mq::stomp_client | [private] |
send(const std::string &topic, const std::string &message) | moost::mq::stomp_client | |
stomp_client(size_t consumer_pool_size=1, const boost::posix_time::time_duration &keepalive_interval=boost::posix_time::seconds(30), const boost::posix_time::time_duration &reconnect_interval=boost::posix_time::seconds(1)) | moost::mq::stomp_client | |
subscribe(const std::string &topic, boost::function< void(const std::string &)> message_cb, ack::type ack_type=ack::automatic, const boost::posix_time::time_duration &max_msg_interval=boost::posix_time::pos_infin) | moost::mq::stomp_client | |
unsubscribe(const std::string &topic) | moost::mq::stomp_client | |
~stomp_client() | moost::mq::stomp_client |