libmoost
Public Types | Public Member Functions | Private Attributes
moost::mq::stream Class Reference

#include <stream.hpp>

List of all members.

Public Types

typedef boost::function< void(const
std::string &)> 		message_cb_t

Public Member Functions

 stream (const message_cb_t &cb, stomp_client::ack::type ack_type, const boost::posix_time::time_duration &max_msg_interval)
void invoke (const std::string &message)
void reset_interval_timer ()
stomp_client::ack::type ack_type () const
const
boost::posix_time::time_duration & 		max_msg_interval ()
bool max_msg_interval_exceeded () const

Private Attributes

message_cb_t m_callback
boost::posix_time::ptime m_last_invoke
const stomp_client::ack::type m_ack_type
const
boost::posix_time::time_duration 		m_max_msg_interval

Detailed Description

Definition at line 40 of file stream.hpp.

Member Typedef Documentation

typedef boost::function<void (const std::string&)> moost::mq::stream::message_cb_t

Definition at line 43 of file stream.hpp.

Constructor & Destructor Documentation

moost::mq::stream::stream ( const message_cb_t &  cb,
stomp_client::ack::type  ack_type,
const boost::posix_time::time_duration &  max_msg_interval 
) [inline]

Definition at line 45 of file stream.hpp.

Member Function Documentation

stomp_client::ack::type moost::mq::stream::ack_type ( ) const [inline]

Definition at line 70 of file stream.hpp.

void moost::mq::stream::invoke ( const std::string &  message) [inline]

Definition at line 54 of file stream.hpp.

Here is the call graph for this function:

const boost::posix_time::time_duration& moost::mq::stream::max_msg_interval ( ) [inline]

Definition at line 75 of file stream.hpp.

bool moost::mq::stream::max_msg_interval_exceeded ( ) const [inline]

Definition at line 80 of file stream.hpp.

void moost::mq::stream::reset_interval_timer ( ) [inline]

Definition at line 60 of file stream.hpp.

Here is the caller graph for this function:

Member Data Documentation

const stomp_client::ack::type moost::mq::stream::m_ack_type [private]

Definition at line 95 of file stream.hpp.

message_cb_t moost::mq::stream::m_callback [private]

Definition at line 92 of file stream.hpp.

boost::posix_time::ptime moost::mq::stream::m_last_invoke [private]

Definition at line 93 of file stream.hpp.

const boost::posix_time::time_duration moost::mq::stream::m_max_msg_interval [private]

Definition at line 96 of file stream.hpp.

The documentation for this class was generated from the following file: