Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <ClusterConnectionDeliveryRecordBody.h>
Public Types | |
typedef void | ResultType |
Public Member Functions | |
ClusterConnectionDeliveryRecordBody (ProtocolVersion, 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) | |
ClusterConnectionDeliveryRecordBody (ProtocolVersion=ProtocolVersion()) | |
void | setQueue (const string &_queue) |
const string & | getQueue () const |
bool | hasQueue () const |
void | clearQueueFlag () |
void | setPosition (const SequenceNumber &_position) |
SequenceNumber | getPosition () const |
bool | hasPosition () const |
void | clearPositionFlag () |
void | setTag (const string &_tag) |
const string & | getTag () const |
bool | hasTag () const |
void | clearTagFlag () |
void | setId (const SequenceNumber &_id) |
SequenceNumber | getId () const |
bool | hasId () const |
void | clearIdFlag () |
void | setAcquired (bool _acquired) |
bool | getAcquired () const |
void | setAccepted (bool _accepted) |
bool | getAccepted () const |
void | setCancelled (bool _cancelled) |
bool | getCancelled () const |
void | setCompleted (bool _completed) |
bool | getCompleted () const |
void | setEnded (bool _ended) |
bool | getEnded () const |
void | setWindowing (bool _windowing) |
bool | getWindowing () const |
void | setEnqueued (bool _enqueued) |
bool | getEnqueued () const |
void | setCredit (uint32_t _credit) |
uint32_t | getCredit () const |
bool | hasCredit () const |
void | clearCreditFlag () |
template<class T > | |
ResultType | invoke (T &invocable) const |
void | accept (MethodBodyConstVisitor &v) const |
boost::intrusive_ptr< AMQBody > | clone () const |
ClassId | amqpClassId () const |
MethodId | amqpMethodId () const |
bool | isContentBearing () const |
bool | resultExpected () const |
bool | responseExpected () const |
void | encode (Buffer &) const |
void | decode (Buffer &, uint32_t=0) |
void | encodeStructBody (Buffer &) const |
void | decodeStructBody (Buffer &, uint32_t=0) |
uint32_t | encodedSize () const |
uint32_t | bodySize () const |
void | print (std::ostream &out) const |
virtual void | encodeHeader (Buffer &buffer) const |
virtual void | decodeHeader (Buffer &buffer, uint32_t size=0) |
virtual uint32_t | headerSize () const |
virtual bool | isSync () const |
virtual void | setSync (bool on) const |
Header & | getHeader () |
const Header & | getHeader () const |
void | accept (AMQBodyConstVisitor &v) const |
template<class T > | |
bool | isA () const |
virtual uint8_t | type () const |
AMQMethodBody * | getMethod () |
const AMQMethodBody * | getMethod () const |
Static Public Member Functions | |
static bool | match (const AMQBody &, const AMQBody &) |
Match if same type and same class/method ID for methods. | |
Static Public Attributes | |
static const ClassId | CLASS_ID = 0x81 |
static const MethodId | METHOD_ID = 0x11 |
Definition at line 42 of file ClusterConnectionDeliveryRecordBody.h.
Definition at line 120 of file ClusterConnectionDeliveryRecordBody.h.
qpid::framing::ClusterConnectionDeliveryRecordBody::ClusterConnectionDeliveryRecordBody | ( | ProtocolVersion | , | |
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 | |||
) | [inline] |
Definition at line 52 of file ClusterConnectionDeliveryRecordBody.h.
References setAccepted(), setAcquired(), setCancelled(), setCompleted(), setEnded(), setEnqueued(), and setWindowing().
qpid::framing::ClusterConnectionDeliveryRecordBody::ClusterConnectionDeliveryRecordBody | ( | ProtocolVersion | = ProtocolVersion() |
) | [inline] |
Definition at line 84 of file ClusterConnectionDeliveryRecordBody.h.
void qpid::framing::AMQMethodBody::accept | ( | AMQBodyConstVisitor & | v | ) | const [inline, virtual, inherited] |
Implements qpid::framing::AMQBody.
Definition at line 65 of file AMQMethodBody.h.
References qpid::framing::AMQBodyConstVisitor::visit().
void qpid::framing::ClusterConnectionDeliveryRecordBody::accept | ( | MethodBodyConstVisitor & | v | ) | const [inline, virtual] |
Implements qpid::framing::AMQMethodBody.
Definition at line 127 of file ClusterConnectionDeliveryRecordBody.h.
References qpid::framing::MethodBodyConstVisitor::visit().
ClassId qpid::framing::ClusterConnectionDeliveryRecordBody::amqpClassId | ( | ) | const [inline, virtual] |
Implements qpid::framing::AMQMethodBody.
Definition at line 130 of file ClusterConnectionDeliveryRecordBody.h.
References CLASS_ID.
MethodId qpid::framing::ClusterConnectionDeliveryRecordBody::amqpMethodId | ( | ) | const [inline, virtual] |
Implements qpid::framing::AMQMethodBody.
Definition at line 131 of file ClusterConnectionDeliveryRecordBody.h.
References METHOD_ID.
uint32_t qpid::framing::ClusterConnectionDeliveryRecordBody::bodySize | ( | ) | const |
void qpid::framing::ClusterConnectionDeliveryRecordBody::clearCreditFlag | ( | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::clearIdFlag | ( | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::clearPositionFlag | ( | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::clearQueueFlag | ( | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::clearTagFlag | ( | ) |
boost::intrusive_ptr<AMQBody> qpid::framing::ClusterConnectionDeliveryRecordBody::clone | ( | ) | const [inline, virtual] |
Implements qpid::framing::AMQBody.
Definition at line 128 of file ClusterConnectionDeliveryRecordBody.h.
References qpid::framing::BodyFactory::copy().
void qpid::framing::ClusterConnectionDeliveryRecordBody::decode | ( | Buffer & | , | |
uint32_t | = 0 | |||
) | [virtual] |
Implements qpid::framing::AMQBody.
virtual void qpid::framing::ModelMethod::decodeHeader | ( | Buffer & | buffer, | |
uint32_t | size = 0 | |||
) | [inline, virtual, inherited] |
void qpid::framing::ClusterConnectionDeliveryRecordBody::decodeStructBody | ( | Buffer & | , | |
uint32_t | = 0 | |||
) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::encode | ( | Buffer & | ) | const [virtual] |
Implements qpid::framing::AMQBody.
uint32_t qpid::framing::ClusterConnectionDeliveryRecordBody::encodedSize | ( | ) | const [virtual] |
Implements qpid::framing::AMQMethodBody.
virtual void qpid::framing::ModelMethod::encodeHeader | ( | Buffer & | buffer | ) | const [inline, virtual, inherited] |
void qpid::framing::ClusterConnectionDeliveryRecordBody::encodeStructBody | ( | Buffer & | ) | const |
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getAccepted | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getAcquired | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getCancelled | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getCompleted | ( | ) | const |
Referenced by invoke().
uint32_t qpid::framing::ClusterConnectionDeliveryRecordBody::getCredit | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getEnded | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getEnqueued | ( | ) | const |
Referenced by invoke().
const Header& qpid::framing::ModelMethod::getHeader | ( | ) | const [inline, inherited] |
Definition at line 42 of file ModelMethod.h.
Header& qpid::framing::ModelMethod::getHeader | ( | ) | [inline, inherited] |
Definition at line 41 of file ModelMethod.h.
SequenceNumber qpid::framing::ClusterConnectionDeliveryRecordBody::getId | ( | ) | const |
Referenced by invoke().
const AMQMethodBody* qpid::framing::AMQMethodBody::getMethod | ( | ) | const [inline, virtual, inherited] |
AMQMethodBody* qpid::framing::AMQMethodBody::getMethod | ( | ) | [inline, virtual, inherited] |
SequenceNumber qpid::framing::ClusterConnectionDeliveryRecordBody::getPosition | ( | ) | const |
Referenced by invoke().
const string& qpid::framing::ClusterConnectionDeliveryRecordBody::getQueue | ( | ) | const |
Referenced by invoke().
const string& qpid::framing::ClusterConnectionDeliveryRecordBody::getTag | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::getWindowing | ( | ) | const |
Referenced by invoke().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::hasCredit | ( | ) | const |
bool qpid::framing::ClusterConnectionDeliveryRecordBody::hasId | ( | ) | const |
bool qpid::framing::ClusterConnectionDeliveryRecordBody::hasPosition | ( | ) | const |
bool qpid::framing::ClusterConnectionDeliveryRecordBody::hasQueue | ( | ) | const |
bool qpid::framing::ClusterConnectionDeliveryRecordBody::hasTag | ( | ) | const |
virtual uint32_t qpid::framing::ModelMethod::headerSize | ( | ) | const [inline, virtual, inherited] |
ResultType qpid::framing::ClusterConnectionDeliveryRecordBody::invoke | ( | T & | invocable | ) | const [inline] |
Definition at line 122 of file ClusterConnectionDeliveryRecordBody.h.
References getAccepted(), getAcquired(), getCancelled(), getCompleted(), getCredit(), getEnded(), getEnqueued(), getId(), getPosition(), getQueue(), getTag(), and getWindowing().
bool qpid::framing::AMQMethodBody::isA | ( | ) | const [inline, inherited] |
Definition at line 53 of file AMQMethodBody.h.
References qpid::framing::AMQMethodBody::amqpClassId(), and qpid::framing::AMQMethodBody::amqpMethodId().
Referenced by qpid::framing::FrameSet::as(), and qpid::framing::FrameSet::isA().
bool qpid::framing::ClusterConnectionDeliveryRecordBody::isContentBearing | ( | ) | const [inline, virtual] |
Implements qpid::framing::AMQMethodBody.
Definition at line 132 of file ClusterConnectionDeliveryRecordBody.h.
virtual bool qpid::framing::ModelMethod::isSync | ( | ) | const [inline, virtual, inherited] |
Reimplemented from qpid::framing::AMQMethodBody.
Definition at line 39 of file ModelMethod.h.
References qpid::framing::Header::getSync().
Match if same type and same class/method ID for methods.
void qpid::framing::ClusterConnectionDeliveryRecordBody::print | ( | std::ostream & | out | ) | const [virtual] |
Implements qpid::framing::AMQBody.
bool qpid::framing::ClusterConnectionDeliveryRecordBody::responseExpected | ( | ) | const [inline, virtual] |
Implements qpid::framing::AMQMethodBody.
Definition at line 134 of file ClusterConnectionDeliveryRecordBody.h.
bool qpid::framing::ClusterConnectionDeliveryRecordBody::resultExpected | ( | ) | const [inline, virtual] |
Implements qpid::framing::AMQMethodBody.
Definition at line 133 of file ClusterConnectionDeliveryRecordBody.h.
void qpid::framing::ClusterConnectionDeliveryRecordBody::setAccepted | ( | bool | _accepted | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setAcquired | ( | bool | _acquired | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setCancelled | ( | bool | _cancelled | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setCompleted | ( | bool | _completed | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setCredit | ( | uint32_t | _credit | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::setEnded | ( | bool | _ended | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setEnqueued | ( | bool | _enqueued | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setId | ( | const SequenceNumber & | _id | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::setPosition | ( | const SequenceNumber & | _position | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::setQueue | ( | const string & | _queue | ) |
virtual void qpid::framing::ModelMethod::setSync | ( | bool | on | ) | const [inline, virtual, inherited] |
Reimplemented from qpid::framing::AMQMethodBody.
Definition at line 40 of file ModelMethod.h.
References qpid::framing::Header::setSync().
void qpid::framing::ClusterConnectionDeliveryRecordBody::setTag | ( | const string & | _tag | ) |
void qpid::framing::ClusterConnectionDeliveryRecordBody::setWindowing | ( | bool | _windowing | ) |
Referenced by ClusterConnectionDeliveryRecordBody().
virtual uint8_t qpid::framing::AMQMethodBody::type | ( | ) | const [inline, virtual, inherited] |
Implements qpid::framing::AMQBody.
Reimplemented in qpid::framing::ConnectionCloseBody, qpid::framing::ConnectionCloseOkBody, qpid::framing::ConnectionHeartbeatBody, qpid::framing::ConnectionOpenBody, qpid::framing::ConnectionOpenOkBody, qpid::framing::ConnectionRedirectBody, qpid::framing::ConnectionSecureBody, qpid::framing::ConnectionSecureOkBody, qpid::framing::ConnectionStartBody, qpid::framing::ConnectionStartOkBody, qpid::framing::ConnectionTuneBody, qpid::framing::ConnectionTuneOkBody, qpid::framing::SessionAttachBody, qpid::framing::SessionAttachedBody, qpid::framing::SessionCommandPointBody, qpid::framing::SessionCompletedBody, qpid::framing::SessionConfirmedBody, qpid::framing::SessionDetachBody, qpid::framing::SessionDetachedBody, qpid::framing::SessionExpectedBody, qpid::framing::SessionFlushBody, qpid::framing::SessionGapBody, qpid::framing::SessionKnownCompletedBody, qpid::framing::SessionRequestTimeoutBody, and qpid::framing::SessionTimeoutBody.
Definition at line 58 of file AMQMethodBody.h.
References qpid::framing::METHOD_BODY.
const ClassId qpid::framing::ClusterConnectionDeliveryRecordBody::CLASS_ID = 0x81 [static] |
const MethodId qpid::framing::ClusterConnectionDeliveryRecordBody::METHOD_ID = 0x11 [static] |