Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <Dispatcher.h>
Public Member Functions | |
Dispatcher (const Session &session, const std::string &queue="") | |
~Dispatcher () | |
void | start () |
void | wait () |
void | run () |
void | stop () |
void | setAutoStop (bool b) |
void | registerFailoverHandler (boost::function< void()> fh) |
void | listen (const boost::intrusive_ptr< SubscriptionImpl > &subscription) |
void | cancel (const std::string &destination) |
Definition at line 46 of file Dispatcher.h.
qpid::client::Dispatcher::Dispatcher | ( | const Session & | session, | |
const std::string & | queue = "" | |||
) |
qpid::client::Dispatcher::~Dispatcher | ( | ) | [inline] |
Definition at line 66 of file Dispatcher.h.
void qpid::client::Dispatcher::cancel | ( | const std::string & | destination | ) |
void qpid::client::Dispatcher::listen | ( | const boost::intrusive_ptr< SubscriptionImpl > & | subscription | ) |
void qpid::client::Dispatcher::registerFailoverHandler | ( | boost::function< void()> | fh | ) | [inline] |
Definition at line 76 of file Dispatcher.h.
void qpid::client::Dispatcher::run | ( | ) |
void qpid::client::Dispatcher::setAutoStop | ( | bool | b | ) |
void qpid::client::Dispatcher::start | ( | ) |
void qpid::client::Dispatcher::stop | ( | ) |
void qpid::client::Dispatcher::wait | ( | ) |