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 | announce ()=0 |
virtual void | deliverClose ()=0 |
virtual void | deliverDoOutput (uint32_t limit)=0 |
virtual void | abort ()=0 |
virtual void | consumerState (const string &name, bool blocked, bool notifyEnabled, bool isInListener)=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, bool enqueued, 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 | outputTask (uint16_t channel, const string &name)=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, uint32_t sendMax)=0 |
virtual void | membership (const FieldTable &joiners, const FieldTable &members, uint64_t frameSeq)=0 |
virtual void | retractOffer ()=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 456 of file AMQP_AllOperations.h.
qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::ClusterConnectionHandler | ( | ) | [inline] |
Definition at line 461 of file AMQP_AllOperations.h.
virtual qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::~ClusterConnectionHandler | ( | ) | [inline, virtual] |
Definition at line 462 of file AMQP_AllOperations.h.
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::abort | ( | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::accumulatedAck | ( | const SequenceSet & | commands | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::announce | ( | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::consumerState | ( | const string & | name, | |
bool | blocked, | |||
bool | notifyEnabled, | |||
bool | isInListener | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::deliverClose | ( | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::deliverDoOutput | ( | uint32_t | limit | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::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, | |||
bool | enqueued, | |||
uint32_t | credit | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::exchange | ( | const string & | encoded | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::expiryId | ( | uint64_t | expiryId | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::membership | ( | const FieldTable & | joiners, | |
const FieldTable & | members, | |||
uint64_t | frameSeq | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::outputTask | ( | uint16_t | channel, | |
const string & | name | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::queue | ( | const string & | encoded | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::queuePosition | ( | const string & | queue, | |
const SequenceNumber & | position | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::retractOffer | ( | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::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::AMQP_AllOperations::ClusterConnectionHandler::shadowReady | ( | uint64_t | memberId, | |
uint64_t | connectionId, | |||
const string & | userName, | |||
const string & | fragment, | |||
uint32_t | sendMax | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::txAccept | ( | const SequenceSet & | commands | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::txDequeue | ( | const string & | queue | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::txEnd | ( | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::txEnqueue | ( | const string & | queue | ) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::txPublish | ( | const Array & | queues, | |
bool | delivered | |||
) | [pure virtual] |
virtual void qpid::framing::AMQP_AllOperations::AMQP_AllOperations::ClusterConnectionHandler::txStart | ( | ) | [pure virtual] |