, including all inherited members.
connect(const std::string &hostname, int port, error_cb_t error_cb) | moost::mq::stomp_client::impl | |
connect() | moost::mq::stomp_client::impl | [private] |
dead_conn_detect() | moost::mq::stomp_client::impl | [private] |
disconnect() | moost::mq::stomp_client::impl | |
error_cb_t typedef | moost::mq::stomp_client::impl | |
get_num_pending() const | moost::mq::stomp_client::impl | [inline] |
get_num_processed() const | moost::mq::stomp_client::impl | [inline] |
handle_dead_conn(const boost::system::error_code &err) | moost::mq::stomp_client::impl | [private] |
handle_keepalive(const boost::system::error_code &err) | moost::mq::stomp_client::impl | [private] |
handle_reconnect(const boost::system::error_code &err) | moost::mq::stomp_client::impl | [private] |
handle_recv(const boost::system::error_code &err) | moost::mq::stomp_client::impl | [private] |
handle_stomp_error(const header_map &headers, const std::string &body) | moost::mq::stomp_client::impl | [private] |
handle_write(boost::shared_ptr< boost::asio::streambuf >, const boost::system::error_code &err) | moost::mq::stomp_client::impl | [private] |
header_map typedef | moost::mq::stomp_client::impl | [private] |
impl(size_t consumer_pool_size, const boost::posix_time::time_duration &keepalive_interval, const boost::posix_time::time_duration &reconnect_interval) | moost::mq::stomp_client::impl | |
is_connected() const | moost::mq::stomp_client::impl | [inline] |
is_online() const | moost::mq::stomp_client::impl | [inline] |
keepalive() | moost::mq::stomp_client::impl | [private] |
m_dead_conn_timer | moost::mq::stomp_client::impl | [private] |
m_error_cb | moost::mq::stomp_client::impl | [private] |
m_hostname | moost::mq::stomp_client::impl | [private] |
m_ios | moost::mq::stomp_client::impl | [private] |
m_ios_thread | moost::mq::stomp_client::impl | [private] |
m_ios_work | moost::mq::stomp_client::impl | [private] |
m_keepalive_interval | moost::mq::stomp_client::impl | [private] |
m_keepalive_timer | moost::mq::stomp_client::impl | [private] |
m_port | moost::mq::stomp_client::impl | [private] |
m_proto | moost::mq::stomp_client::impl | [private] |
m_reconnect_interval | moost::mq::stomp_client::impl | [private] |
m_reconnect_timer | moost::mq::stomp_client::impl | [private] |
m_response | moost::mq::stomp_client::impl | [private] |
m_socket | moost::mq::stomp_client::impl | [private] |
m_state | moost::mq::stomp_client::impl | [private] |
m_streams | moost::mq::stomp_client::impl | [private] |
make_error_code(error::type ec) | moost::mq::stomp_client::impl | [private, static] |
on_message(const header_map &headers, const std::string &msg) | moost::mq::stomp_client::impl | [private] |
receive_from_queue(std::string &command, header_map &headers, std::string &body) | moost::mq::stomp_client::impl | [private] |
reconnect() | moost::mq::stomp_client::impl | [private] |
recv_more() | moost::mq::stomp_client::impl | [private] |
send(const std::string &topic, const std::string &message) | moost::mq::stomp_client::impl | |
send_to_queue(const std::string &command, const std::string &body=std::string()) | moost::mq::stomp_client::impl | [private] |
send_to_queue(const std::string &command, const header_map &headers, const std::string &body=std::string()) | moost::mq::stomp_client::impl | [private] |
send_to_queue(const std::string &command, const header_map &headers, const std::string &body, boost::system::error_code *ec) | moost::mq::stomp_client::impl | [private] |
send_to_queue_async(const std::string &command, const std::string &body=std::string()) | moost::mq::stomp_client::impl | [private] |
send_to_queue_async(const std::string &command, const header_map &headers, const std::string &body=std::string()) | moost::mq::stomp_client::impl | [private] |
subscribe(const std::string &topic, stream::message_cb_t message_cb, stomp_client::ack::type ack_type, const boost::posix_time::time_duration &max_msg_interval) | moost::mq::stomp_client::impl | |
subscribe(const std::string &topic, stomp_client::ack::type ack_type) | moost::mq::stomp_client::impl | [private] |
unsubscribe(const std::string &topic) | moost::mq::stomp_client::impl | |
~impl() | moost::mq::stomp_client::impl | |