| Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <Demux.h>
Classes | |
| struct | Find |
| struct | Record |
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 () |
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 | ) |
1.5.7.1