namespace contains classes that are used to create, send and receive the basic packets from which AMQP is built.
|
Namespaces |
| namespace | connection |
| namespace | dtx |
| namespace | execution |
| namespace | file |
| namespace | message |
| namespace | session |
| namespace | stream |
Classes |
| struct | Range |
| class | AccumulatedAck |
| | Keeps an accumulated record of acknowledged messages (by delivery tag). More...
|
| struct | AMQBodyConstVisitor |
| class | AMQBody |
| class | AMQCommandControlBody |
| | AMQBody wrapper for Command and Control. More...
|
| class | CommandBody |
| class | ControlBody |
| class | AMQContentBody |
| class | AMQDataBlock |
| class | AMQFrame |
| class | AMQHeaderBody |
| class | AMQHeartbeatBody |
| class | AMQMethodBody |
| class | Array |
| class | BodyFactory |
| | Indirect creation of body types to allow centralized changes to memory management strategy. More...
|
| class | BodyHandler |
| | Interface to handle incoming frame bodies. More...
|
| struct | OutOfBounds |
| class | Buffer |
| class | ChannelHandler |
| | Sets the channel number on outgoing frames. More...
|
| class | Endian |
| | Conversion utility for little-endian platforms that need to convert to and from network ordered octet sequences. More...
|
| class | FieldTable |
| | A set of name-value pairs. More...
|
| class | FieldValueException |
| | Exception that is the base exception for all field table errors. More...
|
| struct | InvalidConversionException |
| | Exception thrown when we can't perform requested conversion. More...
|
| class | FieldValue |
| | Value that can appear in an AMQP field table. More...
|
| class | FixedWidthValue |
| class | FixedWidthValue< 0 > |
| class | VariableWidthValue |
| class | EncodedValue |
| class | Str8Value |
| class | Str16Value |
| class | Struct32Value |
| class | FloatValue |
| class | DoubleValue |
| class | IntegerValue |
| class | TimeValue |
| class | Integer64Value |
| class | Unsigned64Value |
| class | FieldTableValue |
| class | ArrayValue |
| class | SumFrameSize |
| class | SumBodySize |
| class | Count |
| class | EncodeFrame |
| class | EncodeBody |
| class | Relay |
| | Sends to the specified handler a copy of the frame it is applied to. More...
|
| class | Print |
| class | MarkLastSegment |
| class | FrameDecoder |
| | Decode a frame from buffer. More...
|
| struct | FrameDefaultVisitor |
| | Visitor for all concrete frame body types, which combines AMQBodyConstVisitor and MethodBodyDefaultVisitor. More...
|
| class | FrameSet |
| | Collects the frames representing a message. More...
|
| struct | Handler |
| class | HeaderProperties |
| class | InitiationHandler |
| class | InputHandler |
| class | Invoker |
| | Base class for invoker visitors. More...
|
| class | MethodBodyFactory |
| | Functions to create instances of AMQMethodBody sub-classes. More...
|
| class | MethodContent |
| class | ModelMethod |
| class | OutputHandler |
| class | ProtocolInitiation |
| class | ProtocolVersion |
| class | Proxy |
| | Base class for proxies. More...
|
| class | SendContent |
| | Functor that sends frame to handler, refragmenting if necessary. More...
|
| class | SequenceNumber |
| | 4-byte sequence number that 'wraps around'. More...
|
| struct | Window |
| class | SequenceNumberSet |
| class | SequenceSet |
| class | StructHelper |
| class | TransferContent |
| | Message content. More...
|
| struct | TypeFilter |
| | Predicate that selects frames by type. More...
|
| struct | TypeFilter2 |
| struct | Uuid |
| | A UUID is represented as a boost::array of 16 bytes. More...
|
| struct | NoBlankVisitor |
| | boost::static_visitor that throws an exception if variant contains a blank. More...
|
| struct | ConvertVisitor |
| | Convert the variant value to type R. More...
|
| struct | AddressVisitor |
| | Convert the address of variant value to type R. More...
|
| struct | ApplyVisitor |
| | Apply a visitor to the nested variant. More...
|
| struct | Visit |
| | visit() interface for type T (optional return type R, default is void. More...
|
| struct | VisitableRoot |
| | The root class for the hierarchy of objects visitable by Visitor V. More...
|
| struct | Visitable |
| | The base class for concrete visitable classes. More...
|
| class | AMQP_AllOperations |
| class | AMQP_AllProxy |
| class | AMQP_ClientOperations |
| class | AMQP_ClientProxy |
| class | AMQP_ServerOperations |
| class | AMQP_ServerProxy |
| class | ClusterConfigChangeBody |
| class | ClusterConnectionAccumulatedAckBody |
| class | ClusterConnectionConsumerStateBody |
| class | ClusterConnectionDeliverCloseBody |
| class | ClusterConnectionDeliverDoOutputBody |
| class | ClusterConnectionDeliveryRecordBody |
| class | ClusterConnectionExchangeBody |
| class | ClusterConnectionExpiryIdBody |
| class | ClusterConnectionMembershipBody |
| class | ClusterConnectionQueueBody |
| class | ClusterConnectionQueuePositionBody |
| class | ClusterConnectionSessionStateBody |
| class | ClusterConnectionShadowReadyBody |
| class | ClusterConnectionTxAcceptBody |
| class | ClusterConnectionTxDequeueBody |
| class | ClusterConnectionTxEndBody |
| class | ClusterConnectionTxEnqueueBody |
| class | ClusterConnectionTxPublishBody |
| class | ClusterConnectionTxStartBody |
| class | ClusterMessageExpiredBody |
| class | ClusterReadyBody |
| class | ClusterShutdownBody |
| class | ClusterUpdateOfferBody |
| class | ClusterUpdateRequestBody |
| class | ConnectionCloseBody |
| class | ConnectionCloseOkBody |
| class | ConnectionHeartbeatBody |
| class | ConnectionOpenBody |
| class | ConnectionOpenOkBody |
| class | ConnectionRedirectBody |
| class | ConnectionSecureBody |
| class | ConnectionSecureOkBody |
| class | ConnectionStartBody |
| class | ConnectionStartOkBody |
| class | ConnectionTuneBody |
| class | ConnectionTuneOkBody |
| class | DeliveryProperties |
| class | DtxCommitBody |
| class | DtxEndBody |
| class | DtxForgetBody |
| class | DtxGetTimeoutBody |
| class | DtxGetTimeoutResult |
| class | DtxPrepareBody |
| class | DtxRecoverBody |
| class | DtxRecoverResult |
| class | DtxRollbackBody |
| class | DtxSelectBody |
| class | DtxSetTimeoutBody |
| class | DtxStartBody |
| class | ExchangeBindBody |
| class | ExchangeBoundBody |
| class | ExchangeBoundResult |
| class | ExchangeDeclareBody |
| class | ExchangeDeleteBody |
| class | ExchangeQueryBody |
| class | ExchangeQueryResult |
| class | ExchangeUnbindBody |
| class | ExecutionExceptionBody |
| class | ExecutionResultBody |
| class | ExecutionSyncBody |
| class | FileAckBody |
| class | FileCancelBody |
| class | FileConsumeBody |
| class | FileConsumeOkBody |
| class | FileDeliverBody |
| class | FileOpenBody |
| class | FileOpenOkBody |
| class | FileProperties |
| class | FilePublishBody |
| class | FileQosBody |
| class | FileQosOkBody |
| class | FileRejectBody |
| class | FileReturnBody |
| class | FileStageBody |
| class | FragmentProperties |
| class | Header |
| class | MessageAcceptBody |
| class | MessageAcquireBody |
| class | MessageAcquireResult |
| class | MessageCancelBody |
| class | MessageFlowBody |
| class | MessageFlushBody |
| class | MessageProperties |
| class | MessageRejectBody |
| class | MessageReleaseBody |
| class | MessageResumeBody |
| class | MessageResumeResult |
| class | MessageSetFlowModeBody |
| class | MessageStopBody |
| class | MessageSubscribeBody |
| class | MessageTransferBody |
| class | MethodBodyConstVisitor |
| class | MethodBodyDefaultVisitor |
| class | QueueDeclareBody |
| class | QueueDeleteBody |
| class | QueuePurgeBody |
| class | QueueQueryBody |
| class | QueueQueryResult |
| struct | UnauthorizedAccessException |
| | The client attempted to work with a server entity to which it has no access due to security settings. More...
|
| struct | NotFoundException |
| | The client attempted to work with a server entity that does not exist. More...
|
| struct | ResourceLockedException |
| | The client attempted to work with a server entity to which it has no access because another client is working with it. More...
|
| struct | PreconditionFailedException |
| | The client requested a command that was not allowed because some precondition failed. More...
|
| struct | ResourceDeletedException |
| | A server entity the client is working with has been deleted. More...
|
| struct | IllegalStateException |
| | The peer sent a command that is not permitted in the current state of the session. More...
|
| struct | CommandInvalidException |
| | The command segments could not be decoded. More...
|
| struct | ResourceLimitExceededException |
| | The client exceeded its resource allocation. More...
|
| struct | NotAllowedException |
| | The peer tried to use a command a manner that is inconsistent with the rules described in the specification. More...
|
| struct | IllegalArgumentException |
| | The command argument is malformed, i.e. More...
|
| struct | NotImplementedException |
| | The peer tried to use functionality that is not implemented in its partner. More...
|
| struct | InternalErrorException |
| | The peer could not complete the command because of an internal error. More...
|
| struct | InvalidArgumentException |
| | An invalid argument was passed to a command, and the operation could not proceed. More...
|
| struct | ConnectionForcedException |
| | An operator intervened to close the connection for some reason. More...
|
| struct | InvalidPathException |
| | The client tried to work with an unknown virtual host. More...
|
| struct | FramingErrorException |
| | A valid frame header cannot be formed from the incoming byte stream. More...
|
| struct | SessionBusyException |
| | The session is currently attached to another transport. More...
|
| struct | TransportBusyException |
| | The transport is currently attached to another session. More...
|
| struct | NotAttachedException |
| | The transport is not currently attached to any session. More...
|
| struct | UnknownIdsException |
| | Command data was received prior to any use of the command-point control. More...
|
| class | ReplyTo |
| class | SessionAttachBody |
| class | SessionAttachedBody |
| class | SessionCommandPointBody |
| class | SessionCompletedBody |
| class | SessionConfirmedBody |
| class | SessionDetachBody |
| class | SessionDetachedBody |
| class | SessionExpectedBody |
| class | SessionFlushBody |
| class | SessionGapBody |
| class | SessionKnownCompletedBody |
| class | SessionRequestTimeoutBody |
| class | SessionTimeoutBody |
| class | StreamCancelBody |
| class | StreamConsumeBody |
| class | StreamConsumeOkBody |
| class | StreamDeliverBody |
| class | StreamProperties |
| class | StreamPublishBody |
| class | StreamQosBody |
| class | StreamQosOkBody |
| class | StreamReturnBody |
| class | TxCommitBody |
| class | TxRollbackBody |
| class | TxSelectBody |
| class | XaResult |
| class | Xid |
Typedefs |
| typedef uint8_t | FrameType |
| typedef uint16_t | ChannelId |
| typedef uint32_t | BatchOffset |
| typedef uint8_t | ClassId |
| typedef uint8_t | MethodId |
| typedef uint16_t | ReplyCode |
| typedef Handler< AMQFrame & > | FrameHandler |
Enumerations |
| enum | BodyTypes { METHOD_BODY = 1,
HEADER_BODY = 2,
CONTENT_BODY = 3,
HEARTBEAT_BODY = 8
} |
| enum | DeliveryMode { TRANSIENT = 1,
PERSISTENT = 2
} |
| enum | AmqpConstant {
MIN_MAX_FRAME_SIZE = 4096,
CONNECTION_CLASS_ID = 0x1,
CONNECTION_START_METHOD_ID = 0x1,
CONNECTION_START_OK_METHOD_ID = 0x2,
CONNECTION_SECURE_METHOD_ID = 0x3,
CONNECTION_SECURE_OK_METHOD_ID = 0x4,
CONNECTION_TUNE_METHOD_ID = 0x5,
CONNECTION_TUNE_OK_METHOD_ID = 0x6,
CONNECTION_OPEN_METHOD_ID = 0x7,
CONNECTION_OPEN_OK_METHOD_ID = 0x8,
CONNECTION_REDIRECT_METHOD_ID = 0x9,
CONNECTION_HEARTBEAT_METHOD_ID = 0xa,
CONNECTION_CLOSE_METHOD_ID = 0xb,
CONNECTION_CLOSE_OK_METHOD_ID = 0xc,
SESSION_CLASS_ID = 0x2,
SESSION_ATTACH_METHOD_ID = 0x1,
SESSION_ATTACHED_METHOD_ID = 0x2,
SESSION_DETACH_METHOD_ID = 0x3,
SESSION_DETACHED_METHOD_ID = 0x4,
SESSION_REQUEST_TIMEOUT_METHOD_ID = 0x5,
SESSION_TIMEOUT_METHOD_ID = 0x6,
SESSION_COMMAND_POINT_METHOD_ID = 0x7,
SESSION_EXPECTED_METHOD_ID = 0x8,
SESSION_CONFIRMED_METHOD_ID = 0x9,
SESSION_COMPLETED_METHOD_ID = 0xa,
SESSION_KNOWN_COMPLETED_METHOD_ID = 0xb,
SESSION_FLUSH_METHOD_ID = 0xc,
SESSION_GAP_METHOD_ID = 0xd,
EXECUTION_CLASS_ID = 0x3,
EXECUTION_SYNC_METHOD_ID = 0x1,
EXECUTION_RESULT_METHOD_ID = 0x2,
EXECUTION_EXCEPTION_METHOD_ID = 0x3,
MESSAGE_CLASS_ID = 0x4,
MESSAGE_TRANSFER_METHOD_ID = 0x1,
MESSAGE_ACCEPT_METHOD_ID = 0x2,
MESSAGE_REJECT_METHOD_ID = 0x3,
MESSAGE_RELEASE_METHOD_ID = 0x4,
MESSAGE_ACQUIRE_METHOD_ID = 0x5,
MESSAGE_RESUME_METHOD_ID = 0x6,
MESSAGE_SUBSCRIBE_METHOD_ID = 0x7,
MESSAGE_CANCEL_METHOD_ID = 0x8,
MESSAGE_SET_FLOW_MODE_METHOD_ID = 0x9,
MESSAGE_FLOW_METHOD_ID = 0xa,
MESSAGE_FLUSH_METHOD_ID = 0xb,
MESSAGE_STOP_METHOD_ID = 0xc,
TX_CLASS_ID = 0x5,
TX_SELECT_METHOD_ID = 0x1,
TX_COMMIT_METHOD_ID = 0x2,
TX_ROLLBACK_METHOD_ID = 0x3,
DTX_CLASS_ID = 0x6,
DTX_SELECT_METHOD_ID = 0x1,
DTX_START_METHOD_ID = 0x2,
DTX_END_METHOD_ID = 0x3,
DTX_COMMIT_METHOD_ID = 0x4,
DTX_FORGET_METHOD_ID = 0x5,
DTX_GET_TIMEOUT_METHOD_ID = 0x6,
DTX_PREPARE_METHOD_ID = 0x7,
DTX_RECOVER_METHOD_ID = 0x8,
DTX_ROLLBACK_METHOD_ID = 0x9,
DTX_SET_TIMEOUT_METHOD_ID = 0xa,
EXCHANGE_CLASS_ID = 0x7,
EXCHANGE_DECLARE_METHOD_ID = 0x1,
EXCHANGE_DELETE_METHOD_ID = 0x2,
EXCHANGE_QUERY_METHOD_ID = 0x3,
EXCHANGE_BIND_METHOD_ID = 0x4,
EXCHANGE_UNBIND_METHOD_ID = 0x5,
EXCHANGE_BOUND_METHOD_ID = 0x6,
QUEUE_CLASS_ID = 0x8,
QUEUE_DECLARE_METHOD_ID = 0x1,
QUEUE_DELETE_METHOD_ID = 0x2,
QUEUE_PURGE_METHOD_ID = 0x3,
QUEUE_QUERY_METHOD_ID = 0x4,
FILE_CLASS_ID = 0x9,
FILE_QOS_METHOD_ID = 0x1,
FILE_QOS_OK_METHOD_ID = 0x2,
FILE_CONSUME_METHOD_ID = 0x3,
FILE_CONSUME_OK_METHOD_ID = 0x4,
FILE_CANCEL_METHOD_ID = 0x5,
FILE_OPEN_METHOD_ID = 0x6,
FILE_OPEN_OK_METHOD_ID = 0x7,
FILE_STAGE_METHOD_ID = 0x8,
FILE_PUBLISH_METHOD_ID = 0x9,
FILE_RETURN_METHOD_ID = 0xa,
FILE_DELIVER_METHOD_ID = 0xb,
FILE_ACK_METHOD_ID = 0xc,
FILE_REJECT_METHOD_ID = 0xd,
STREAM_CLASS_ID = 0xa,
STREAM_QOS_METHOD_ID = 0x1,
STREAM_QOS_OK_METHOD_ID = 0x2,
STREAM_CONSUME_METHOD_ID = 0x3,
STREAM_CONSUME_OK_METHOD_ID = 0x4,
STREAM_CANCEL_METHOD_ID = 0x5,
STREAM_PUBLISH_METHOD_ID = 0x6,
STREAM_RETURN_METHOD_ID = 0x7,
STREAM_DELIVER_METHOD_ID = 0x8,
CLUSTER_CLASS_ID = 0x80,
CLUSTER_UPDATE_REQUEST_METHOD_ID = 0x1,
CLUSTER_UPDATE_OFFER_METHOD_ID = 0x2,
CLUSTER_READY_METHOD_ID = 0x10,
CLUSTER_CONFIG_CHANGE_METHOD_ID = 0x11,
CLUSTER_MESSAGE_EXPIRED_METHOD_ID = 0x12,
CLUSTER_SHUTDOWN_METHOD_ID = 0x20,
CLUSTER_CONNECTION_CLASS_ID = 0x81,
CLUSTER_CONNECTION_DELIVER_CLOSE_METHOD_ID = 0x2,
CLUSTER_CONNECTION_DELIVER_DO_OUTPUT_METHOD_ID = 0x3,
CLUSTER_CONNECTION_CONSUMER_STATE_METHOD_ID = 0x10,
CLUSTER_CONNECTION_DELIVERY_RECORD_METHOD_ID = 0x11,
CLUSTER_CONNECTION_TX_START_METHOD_ID = 0x12,
CLUSTER_CONNECTION_TX_ACCEPT_METHOD_ID = 0x13,
CLUSTER_CONNECTION_TX_DEQUEUE_METHOD_ID = 0x14,
CLUSTER_CONNECTION_TX_ENQUEUE_METHOD_ID = 0x15,
CLUSTER_CONNECTION_TX_PUBLISH_METHOD_ID = 0x16,
CLUSTER_CONNECTION_TX_END_METHOD_ID = 0x17,
CLUSTER_CONNECTION_ACCUMULATED_ACK_METHOD_ID = 0x18,
CLUSTER_CONNECTION_SESSION_STATE_METHOD_ID = 0x1F,
CLUSTER_CONNECTION_SHADOW_READY_METHOD_ID = 0x20,
CLUSTER_CONNECTION_MEMBERSHIP_METHOD_ID = 0x21,
CLUSTER_CONNECTION_QUEUE_POSITION_METHOD_ID = 0x30,
CLUSTER_CONNECTION_EXCHANGE_METHOD_ID = 0x31,
CLUSTER_CONNECTION_QUEUE_METHOD_ID = 0x32,
CLUSTER_CONNECTION_EXPIRY_ID_METHOD_ID = 0x33
} |
| enum | SegmentType { SEGMENT_TYPE_CONTROL = 0,
SEGMENT_TYPE_COMMAND = 1,
SEGMENT_TYPE_HEADER = 2,
SEGMENT_TYPE_BODY = 3
} |
| enum | Track { TRACK_CONTROL = 0,
TRACK_COMMAND = 1
} |
| enum | TypeCode {
TYPE_CODE_BIN8 = 0x00,
TYPE_CODE_INT8 = 0x01,
TYPE_CODE_UINT8 = 0x02,
TYPE_CODE_CHAR = 0x04,
TYPE_CODE_BOOLEAN = 0x08,
TYPE_CODE_BIN16 = 0x10,
TYPE_CODE_INT16 = 0x11,
TYPE_CODE_UINT16 = 0x12,
TYPE_CODE_BIN32 = 0x20,
TYPE_CODE_INT32 = 0x21,
TYPE_CODE_UINT32 = 0x22,
TYPE_CODE_FLOAT = 0x23,
TYPE_CODE_CHAR_UTF32 = 0x27,
TYPE_CODE_BIN64 = 0x30,
TYPE_CODE_INT64 = 0x31,
TYPE_CODE_UINT64 = 0x32,
TYPE_CODE_DOUBLE = 0x33,
TYPE_CODE_DATETIME = 0x38,
TYPE_CODE_BIN128 = 0x40,
TYPE_CODE_UUID = 0x48,
TYPE_CODE_BIN256 = 0x50,
TYPE_CODE_BIN512 = 0x60,
TYPE_CODE_BIN1024 = 0x70,
TYPE_CODE_VBIN8 = 0x80,
TYPE_CODE_STR8_LATIN = 0x84,
TYPE_CODE_STR8 = 0x85,
TYPE_CODE_STR8_UTF16 = 0x86,
TYPE_CODE_VBIN16 = 0x90,
TYPE_CODE_STR16_LATIN = 0x94,
TYPE_CODE_STR16 = 0x95,
TYPE_CODE_STR16_UTF16 = 0x96,
TYPE_CODE_VBIN32 = 0xa0,
TYPE_CODE_MAP = 0xa8,
TYPE_CODE_LIST = 0xa9,
TYPE_CODE_ARRAY = 0xaa,
TYPE_CODE_STRUCT32 = 0xab,
TYPE_CODE_BIN40 = 0xc0,
TYPE_CODE_DEC32 = 0xc8,
TYPE_CODE_BIN72 = 0xd0,
TYPE_CODE_DEC64 = 0xd8,
TYPE_CODE_VOID = 0xf0,
TYPE_CODE_BIT = 0xf1
} |
Functions |
| std::ostream & | operator<< (std::ostream &, const Range &) |
| std::ostream & | operator<< (std::ostream &, const AccumulatedAck &) |
| std::ostream & | operator<< (std::ostream &out, const AMQBody &body) |
| std::ostream & | operator<< (std::ostream &, const AMQFrame &) |
| static ProtocolVersion | highestProtocolVersion (0, 10) |
| std::ostream & | operator<< (std::ostream &, const Buffer &) |
| template<> |
| bool | FieldValue::convertsTo< std::string > () const |
| template<> |
| std::string | FieldValue::get< std::string > () const |
| std::ostream & | operator<< (std::ostream &out, const FieldValue &v) |
| template<class T > |
| bool | getEncodedValue (FieldTable::ValuePtr vptr, T &value) |
| template<class Invocable > |
| Invoker::Result | invoke (Invocable &target, const AMQMethodBody &body) |
| | Invoke an invocable object.
|
| template<class Invocable > |
| Invoker::Result | invoke (Invocable &target, const AMQBody &body) |
| | Invoke an invocable object.
|
| std::ostream & | operator<< (std::ostream &o, const framing::ProtocolInitiation &pi) |
| std::ostream & | operator<< (std::ostream &o, const SequenceNumber &n) |
| std::ostream & | operator<< (std::ostream &, Uuid) |
| | Print in format 1b4e28ba-2fa1-11d2-883f-b9a761bde3fb.
|
| std::istream & | operator>> (std::istream &, Uuid &) |
| | Read from format 1b4e28ba-2fa1-11d2-883f-b9a761bde3fb.
|
| template<class Visitor , class Visitable > |
| Visitor::result_type | applyApplyVisitor (const Visitor &visitor, Visitable &visitable) |
| | Convenience function to construct and apply an ApplyVisitor.
|
| sys::ExceptionHolder | createSessionException (int code, const std::string &text) |
| sys::ExceptionHolder | createConnectionException (int code, const std::string &text) |
| sys::ExceptionHolder | createChannelException (int code, const std::string &text) |
| bool | isTypeCode (uint8_t t) |
| | True if t is a valid TypeCode value.
|
| TypeCode | typeCode (uint8_t) |
| | Throw exception if not a valid TypeCode.
|
| const char * | typeName (TypeCode t) |
| std::ostream & | operator<< (std::ostream &, TypeCode) |
Variables |
| const ChannelId | CHANNEL_MAX = (ChannelId(~1))>>1 |
| | Maximum channel ID used by broker.
|
| const ChannelId | CHANNEL_HIGH_BIT = ChannelId(~CHANNEL_MAX) |
namespace contains classes that are used to create, send and receive the basic packets from which AMQP is built.
