Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <AMQP_ServerProxy.h>
Public Member Functions | |
Stream (FrameHandler &f) | |
virtual void | qos (uint32_t prefetchSize, uint16_t prefetchCount, uint32_t consumeRate, bool global) |
virtual void | consume (const string &queue, const string &consumerTag, bool noLocal, bool exclusive, bool nowait, const FieldTable &arguments) |
virtual void | cancel (const string &consumerTag) |
virtual void | publish (const string &exchange, const string &routingKey, bool mandatory, bool immediate) |
void | send (const AMQBody &) |
ProtocolVersion | getVersion () const |
FrameHandler & | getHandler () |
void | setHandler (FrameHandler &) |
Static Public Member Functions | |
static Stream & | get (AMQP_ServerProxy &proxy) |
Definition at line 352 of file AMQP_ServerProxy.h.
qpid::framing::AMQP_ServerProxy::AMQP_ServerProxy::Stream::Stream | ( | FrameHandler & | f | ) | [inline] |
Definition at line 356 of file AMQP_ServerProxy.h.
virtual void qpid::framing::AMQP_ServerProxy::AMQP_ServerProxy::Stream::cancel | ( | const string & | consumerTag | ) | [virtual] |
virtual void qpid::framing::AMQP_ServerProxy::AMQP_ServerProxy::Stream::consume | ( | const string & | queue, | |
const string & | consumerTag, | |||
bool | noLocal, | |||
bool | exclusive, | |||
bool | nowait, | |||
const FieldTable & | arguments | |||
) | [virtual] |
static Stream& qpid::framing::AMQP_ServerProxy::AMQP_ServerProxy::Stream::get | ( | AMQP_ServerProxy & | proxy | ) | [inline, static] |
Definition at line 357 of file AMQP_ServerProxy.h.
FrameHandler& qpid::framing::Proxy::getHandler | ( | ) | [inherited] |
ProtocolVersion qpid::framing::Proxy::getVersion | ( | ) | const [inherited] |
virtual void qpid::framing::AMQP_ServerProxy::AMQP_ServerProxy::Stream::publish | ( | const string & | exchange, | |
const string & | routingKey, | |||
bool | mandatory, | |||
bool | immediate | |||
) | [virtual] |
virtual void qpid::framing::AMQP_ServerProxy::AMQP_ServerProxy::Stream::qos | ( | uint32_t | prefetchSize, | |
uint16_t | prefetchCount, | |||
uint32_t | consumeRate, | |||
bool | global | |||
) | [virtual] |
void qpid::framing::Proxy::send | ( | const AMQBody & | ) | [inherited] |
void qpid::framing::Proxy::setHandler | ( | FrameHandler & | ) | [inherited] |