libmoost
moost::mq::stomp_client::impl Member List
This is the complete list of members for moost::mq::stomp_client::impl, 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 typedefmoost::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 typedefmoost::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_timermoost::mq::stomp_client::impl [private]
m_error_cbmoost::mq::stomp_client::impl [private]
m_hostnamemoost::mq::stomp_client::impl [private]
m_iosmoost::mq::stomp_client::impl [private]
m_ios_threadmoost::mq::stomp_client::impl [private]
m_ios_workmoost::mq::stomp_client::impl [private]
m_keepalive_intervalmoost::mq::stomp_client::impl [private]
m_keepalive_timermoost::mq::stomp_client::impl [private]
m_portmoost::mq::stomp_client::impl [private]
m_protomoost::mq::stomp_client::impl [private]
m_reconnect_intervalmoost::mq::stomp_client::impl [private]
m_reconnect_timermoost::mq::stomp_client::impl [private]
m_responsemoost::mq::stomp_client::impl [private]
m_socketmoost::mq::stomp_client::impl [private]
m_statemoost::mq::stomp_client::impl [private]
m_streamsmoost::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