libmoost
moost::mq::stream_manager Member List
This is the complete list of members for moost::mq::stream_manager, including all inherited members.
clear()moost::mq::stream_manager
consumer_thread()moost::mq::stream_manager [private]
erase(const std::string &topic)moost::mq::stream_manager
get_list(std::vector< topic_stream_pair > &topics) const moost::mq::stream_manager
get_num_pending() const moost::mq::stream_manager [inline]
get_num_processed() const moost::mq::stream_manager [inline]
insert(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::stream_manager
m_cond_messages_listmoost::mq::stream_manager [private]
m_consumer_threadsmoost::mq::stream_manager [private]
m_messages_listmoost::mq::stream_manager [private]
m_mx_messages_listmoost::mq::stream_manager [mutable, private]
m_mx_num_processedmoost::mq::stream_manager [mutable, private]
m_mx_streamsmoost::mq::stream_manager [mutable, private]
m_num_processedmoost::mq::stream_manager [private]
m_runningmoost::mq::stream_manager [private]
m_streamsmoost::mq::stream_manager [private]
max_msg_interval_exceeded() const moost::mq::stream_manager
push_message(const std::string &topic, const std::string &message, stomp_client::ack::type &ack_type)moost::mq::stream_manager
stream_manager(size_t consumer_pool_size)moost::mq::stream_manager
stream_map typedefmoost::mq::stream_manager [private]
stream_message_pair typedefmoost::mq::stream_manager [private]
stream_ptr typedefmoost::mq::stream_manager
topic_stream_pair typedefmoost::mq::stream_manager
~stream_manager()moost::mq::stream_manager