Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <Demux.h>
Public Types | |
typedef boost::function< bool(const framing::FrameSet &)> | Condition |
typedef sys::BlockingQueue< framing::FrameSet::shared_ptr > | Queue |
typedef boost::shared_ptr< Queue > | QueuePtr |
Public Member Functions | |
Demux () | |
~Demux () | |
void | handle (framing::FrameSet::shared_ptr) |
void | close (const sys::ExceptionHolder &ex) |
void | open () |
QueuePtr | add (const std::string &name, Condition) |
void | remove (const std::string &name) |
QueuePtr | get (const std::string &name) |
QueuePtr | getDefault () |
Classes | |
struct | Find |
struct | Record |
Definition at line 45 of file Demux.h.
typedef boost::function<bool(const framing::FrameSet&)> qpid::client::Demux::Condition |
typedef sys::BlockingQueue<framing::FrameSet::shared_ptr> qpid::client::Demux::Queue |
typedef boost::shared_ptr<Queue> qpid::client::Demux::QueuePtr |
qpid::client::Demux::Demux | ( | ) |
qpid::client::Demux::~Demux | ( | ) |
void qpid::client::Demux::close | ( | const sys::ExceptionHolder & | ex | ) |
QueuePtr qpid::client::Demux::get | ( | const std::string & | name | ) |
QueuePtr qpid::client::Demux::getDefault | ( | ) |
void qpid::client::Demux::handle | ( | framing::FrameSet::shared_ptr | ) |
void qpid::client::Demux::open | ( | ) |
void qpid::client::Demux::remove | ( | const std::string & | name | ) |