Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <AMQP_AllProxy.h>
Public Member Functions | |
ClusterConnection (FrameHandler &f) | |
virtual void | deliverClose () |
virtual void | deliverDoOutput (uint32_t bytes) |
virtual void | consumerState (const string &name, bool blocked, bool notifyEnabled) |
virtual void | deliveryRecord (const string &queue, const SequenceNumber &position, const string &tag, const SequenceNumber &id, bool acquired, bool accepted, bool cancelled, bool completed, bool ended, bool windowing, uint32_t credit) |
virtual void | txStart () |
virtual void | txAccept (const SequenceSet &commands) |
virtual void | txDequeue (const string &queue) |
virtual void | txEnqueue (const string &queue) |
virtual void | txPublish (const Array &queues, bool delivered) |
virtual void | txEnd () |
virtual void | accumulatedAck (const SequenceSet &commands) |
virtual void | sessionState (const SequenceNumber &replayStart, const SequenceNumber &commandPoint, const SequenceSet &sentIncomplete, const SequenceNumber &expected, const SequenceNumber &received, const SequenceSet &unknownCompleted, const SequenceSet &receivedIncomplete) |
virtual void | shadowReady (uint64_t memberId, uint64_t connectionId, const string &userName, const string &fragment) |
virtual void | membership (const FieldTable &joiners, const FieldTable &members) |
virtual void | queuePosition (const string &queue, const SequenceNumber &position) |
virtual void | exchange (const string &encoded) |
virtual void | queue (const string &encoded) |
virtual void | expiryId (uint64_t expiryId) |
void | send (const AMQBody &) |
ProtocolVersion | getVersion () const |
FrameHandler & | getHandler () |
void | setHandler (FrameHandler &) |
Static Public Member Functions | |
static ClusterConnection & | get (AMQP_AllProxy &proxy) |
Definition at line 449 of file AMQP_AllProxy.h.
qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::ClusterConnection | ( | FrameHandler & | f | ) | [inline] |
Definition at line 453 of file AMQP_AllProxy.h.
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::accumulatedAck | ( | const SequenceSet & | commands | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::consumerState | ( | const string & | name, | |
bool | blocked, | |||
bool | notifyEnabled | |||
) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::deliverClose | ( | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::deliverDoOutput | ( | uint32_t | bytes | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::deliveryRecord | ( | const string & | queue, | |
const SequenceNumber & | position, | |||
const string & | tag, | |||
const SequenceNumber & | id, | |||
bool | acquired, | |||
bool | accepted, | |||
bool | cancelled, | |||
bool | completed, | |||
bool | ended, | |||
bool | windowing, | |||
uint32_t | credit | |||
) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::exchange | ( | const string & | encoded | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::expiryId | ( | uint64_t | expiryId | ) | [virtual] |
static ClusterConnection& qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::get | ( | AMQP_AllProxy & | proxy | ) | [inline, static] |
Definition at line 454 of file AMQP_AllProxy.h.
FrameHandler& qpid::framing::Proxy::getHandler | ( | ) | [inherited] |
ProtocolVersion qpid::framing::Proxy::getVersion | ( | ) | const [inherited] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::membership | ( | const FieldTable & | joiners, | |
const FieldTable & | members | |||
) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::queue | ( | const string & | encoded | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::queuePosition | ( | const string & | queue, | |
const SequenceNumber & | position | |||
) | [virtual] |
void qpid::framing::Proxy::send | ( | const AMQBody & | ) | [inherited] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::sessionState | ( | const SequenceNumber & | replayStart, | |
const SequenceNumber & | commandPoint, | |||
const SequenceSet & | sentIncomplete, | |||
const SequenceNumber & | expected, | |||
const SequenceNumber & | received, | |||
const SequenceSet & | unknownCompleted, | |||
const SequenceSet & | receivedIncomplete | |||
) | [virtual] |
void qpid::framing::Proxy::setHandler | ( | FrameHandler & | ) | [inherited] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::shadowReady | ( | uint64_t | memberId, | |
uint64_t | connectionId, | |||
const string & | userName, | |||
const string & | fragment | |||
) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::txAccept | ( | const SequenceSet & | commands | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::txDequeue | ( | const string & | queue | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::txEnd | ( | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::txEnqueue | ( | const string & | queue | ) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::txPublish | ( | const Array & | queues, | |
bool | delivered | |||
) | [virtual] |
virtual void qpid::framing::AMQP_AllProxy::AMQP_AllProxy::ClusterConnection::txStart | ( | ) | [virtual] |