| Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <AMQP_AllOperations.h>
Classes | |
| class | Invoker |
Public Member Functions | |
| ClusterConnectionHandler () | |
| virtual | ~ClusterConnectionHandler () |
| virtual void | deliverClose ()=0 |
| virtual void | deliverDoOutput (uint32_t bytes)=0 |
| virtual void | consumerState (const string &name, bool blocked, bool notifyEnabled)=0 |
| 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)=0 |
| virtual void | txStart ()=0 |
| virtual void | txAccept (const SequenceSet &commands)=0 |
| virtual void | txDequeue (const string &queue)=0 |
| virtual void | txEnqueue (const string &queue)=0 |
| virtual void | txPublish (const Array &queues, bool delivered)=0 |
| virtual void | txEnd ()=0 |
| virtual void | accumulatedAck (const SequenceSet &commands)=0 |
| virtual void | sessionState (const SequenceNumber &replayStart, const SequenceNumber &commandPoint, const SequenceSet &sentIncomplete, const SequenceNumber &expected, const SequenceNumber &received, const SequenceSet &unknownCompleted, const SequenceSet &receivedIncomplete)=0 |
| virtual void | shadowReady (uint64_t memberId, uint64_t connectionId, const string &userName, const string &fragment)=0 |
| virtual void | membership (const FieldTable &joiners, const FieldTable &members)=0 |
| virtual void | queuePosition (const string &queue, const SequenceNumber &position)=0 |
| virtual void | exchange (const string &encoded)=0 |
| virtual void | queue (const string &encoded)=0 |
| virtual void | expiryId (uint64_t expiryId)=0 |
Definition at line 450 of file AMQP_AllOperations.h.
| qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::ClusterConnectionHandler | ( | ) | [inline] |
Definition at line 455 of file AMQP_AllOperations.h.
| virtual qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::~ClusterConnectionHandler | ( | ) | [inline, virtual] |
Definition at line 456 of file AMQP_AllOperations.h.
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::accumulatedAck | ( | const SequenceSet & | commands | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::consumerState | ( | const string & | name, | |
| bool | blocked, | |||
| bool | notifyEnabled | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::deliverClose | ( | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::deliverDoOutput | ( | uint32_t | bytes | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::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 | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::exchange | ( | const string & | encoded | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::expiryId | ( | uint64_t | expiryId | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::membership | ( | const FieldTable & | joiners, | |
| const FieldTable & | members | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::queue | ( | const string & | encoded | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::queuePosition | ( | const string & | queue, | |
| const SequenceNumber & | position | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::sessionState | ( | const SequenceNumber & | replayStart, | |
| const SequenceNumber & | commandPoint, | |||
| const SequenceSet & | sentIncomplete, | |||
| const SequenceNumber & | expected, | |||
| const SequenceNumber & | received, | |||
| const SequenceSet & | unknownCompleted, | |||
| const SequenceSet & | receivedIncomplete | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::shadowReady | ( | uint64_t | memberId, | |
| uint64_t | connectionId, | |||
| const string & | userName, | |||
| const string & | fragment | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::txAccept | ( | const SequenceSet & | commands | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::txDequeue | ( | const string & | queue | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::txEnd | ( | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::txEnqueue | ( | const string & | queue | ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::txPublish | ( | const Array & | queues, | |
| bool | delivered | |||
| ) | [pure virtual] |
| virtual void qpid::framing::AMQP_AllOperations::ClusterConnectionHandler::txStart | ( | ) | [pure virtual] |
1.5.7.1