Apache Qpid C++ API
Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation

qpid::framing Namespace Reference

The framing namespace contains classes that are used to create, send and receive the basic packets from which AMQP is built. More...


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  ClusterConnectionAbortBody
class  ClusterConnectionAccumulatedAckBody
class  ClusterConnectionAddQueueListenerBody
class  ClusterConnectionAnnounceBody
class  ClusterConnectionConsumerStateBody
class  ClusterConnectionDeliverCloseBody
class  ClusterConnectionDeliverDoOutputBody
class  ClusterConnectionDeliveryRecordBody
class  ClusterConnectionExchangeBody
class  ClusterConnectionExpiryIdBody
class  ClusterConnectionMembershipBody
class  ClusterConnectionQueueBody
class  ClusterConnectionQueuePositionBody
class  ClusterConnectionRetractOfferBody
class  ClusterConnectionSessionStateBody
class  ClusterConnectionShadowReadyBody
class  ClusterConnectionTxAcceptBody
class  ClusterConnectionTxDequeueBody
class  ClusterConnectionTxEndBody
class  ClusterConnectionTxEnqueueBody
class  ClusterConnectionTxPublishBody
class  ClusterConnectionTxStartBody
class  ClusterErrorCheckBody
class  ClusterMessageExpiredBody
class  ClusterReadyBody
class  ClusterRetractOfferBody
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

Namespaces

namespace  cluster
namespace  connection
namespace  dtx
namespace  execution
namespace  file
namespace  message
namespace  session
namespace  stream

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_RETRACT_OFFER_METHOD_ID = 0x3, CLUSTER_READY_METHOD_ID = 0x10,
  CLUSTER_CONFIG_CHANGE_METHOD_ID = 0x11, CLUSTER_MESSAGE_EXPIRED_METHOD_ID = 0x12, CLUSTER_ERROR_CHECK_METHOD_ID = 0x14, CLUSTER_SHUTDOWN_METHOD_ID = 0x20,
  CLUSTER_CONNECTION_CLASS_ID = 0x81, CLUSTER_CONNECTION_ANNOUNCE_METHOD_ID = 0x1, CLUSTER_CONNECTION_DELIVER_CLOSE_METHOD_ID = 0x2, CLUSTER_CONNECTION_DELIVER_DO_OUTPUT_METHOD_ID = 0x3,
  CLUSTER_CONNECTION_ABORT_METHOD_ID = 0x4, 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_RETRACT_OFFER_METHOD_ID = 0x22, 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, CLUSTER_CONNECTION_ADD_QUEUE_LISTENER_METHOD_ID = 0x34
}
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 &)
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

static ProtocolVersion highestProtocolVersion (0, 10)
const ChannelId CHANNEL_MAX = (ChannelId(~1))>>1
 Maximum channel ID used by broker.
const ChannelId CHANNEL_HIGH_BIT = ChannelId(~CHANNEL_MAX)


Detailed Description

The framing namespace contains classes that are used to create, send and receive the basic packets from which AMQP is built.

Typedef Documentation

typedef uint8_t qpid::framing::FrameType

Definition at line 36 of file amqp_types.h.

typedef uint16_t qpid::framing::ChannelId

Definition at line 37 of file amqp_types.h.

typedef uint32_t qpid::framing::BatchOffset

Definition at line 38 of file amqp_types.h.

typedef uint8_t qpid::framing::ClassId

Definition at line 39 of file amqp_types.h.

typedef uint8_t qpid::framing::MethodId

Definition at line 40 of file amqp_types.h.

typedef uint16_t qpid::framing::ReplyCode

Definition at line 41 of file amqp_types.h.

typedef Handler<AMQFrame&> qpid::framing::FrameHandler

Definition at line 28 of file FrameHandler.h.


Enumeration Type Documentation

enum qpid::framing::BodyTypes

Enumerator:
METHOD_BODY 
HEADER_BODY 
CONTENT_BODY 
HEARTBEAT_BODY 

Definition at line 76 of file AMQBody.h.

enum qpid::framing::DeliveryMode

Enumerator:
TRANSIENT 
PERSISTENT 

Definition at line 37 of file AMQHeaderBody.h.

enum qpid::framing::AmqpConstant

Enumerator:
MIN_MAX_FRAME_SIZE 
CONNECTION_CLASS_ID 
CONNECTION_START_METHOD_ID 
CONNECTION_START_OK_METHOD_ID 
CONNECTION_SECURE_METHOD_ID 
CONNECTION_SECURE_OK_METHOD_ID 
CONNECTION_TUNE_METHOD_ID 
CONNECTION_TUNE_OK_METHOD_ID 
CONNECTION_OPEN_METHOD_ID 
CONNECTION_OPEN_OK_METHOD_ID 
CONNECTION_REDIRECT_METHOD_ID 
CONNECTION_HEARTBEAT_METHOD_ID 
CONNECTION_CLOSE_METHOD_ID 
CONNECTION_CLOSE_OK_METHOD_ID 
SESSION_CLASS_ID 
SESSION_ATTACH_METHOD_ID 
SESSION_ATTACHED_METHOD_ID 
SESSION_DETACH_METHOD_ID 
SESSION_DETACHED_METHOD_ID 
SESSION_REQUEST_TIMEOUT_METHOD_ID 
SESSION_TIMEOUT_METHOD_ID 
SESSION_COMMAND_POINT_METHOD_ID 
SESSION_EXPECTED_METHOD_ID 
SESSION_CONFIRMED_METHOD_ID 
SESSION_COMPLETED_METHOD_ID 
SESSION_KNOWN_COMPLETED_METHOD_ID 
SESSION_FLUSH_METHOD_ID 
SESSION_GAP_METHOD_ID 
EXECUTION_CLASS_ID 
EXECUTION_SYNC_METHOD_ID 
EXECUTION_RESULT_METHOD_ID 
EXECUTION_EXCEPTION_METHOD_ID 
MESSAGE_CLASS_ID 
MESSAGE_TRANSFER_METHOD_ID 
MESSAGE_ACCEPT_METHOD_ID 
MESSAGE_REJECT_METHOD_ID 
MESSAGE_RELEASE_METHOD_ID 
MESSAGE_ACQUIRE_METHOD_ID 
MESSAGE_RESUME_METHOD_ID 
MESSAGE_SUBSCRIBE_METHOD_ID 
MESSAGE_CANCEL_METHOD_ID 
MESSAGE_SET_FLOW_MODE_METHOD_ID 
MESSAGE_FLOW_METHOD_ID 
MESSAGE_FLUSH_METHOD_ID 
MESSAGE_STOP_METHOD_ID 
TX_CLASS_ID 
TX_SELECT_METHOD_ID 
TX_COMMIT_METHOD_ID 
TX_ROLLBACK_METHOD_ID 
DTX_CLASS_ID 
DTX_SELECT_METHOD_ID 
DTX_START_METHOD_ID 
DTX_END_METHOD_ID 
DTX_COMMIT_METHOD_ID 
DTX_FORGET_METHOD_ID 
DTX_GET_TIMEOUT_METHOD_ID 
DTX_PREPARE_METHOD_ID 
DTX_RECOVER_METHOD_ID 
DTX_ROLLBACK_METHOD_ID 
DTX_SET_TIMEOUT_METHOD_ID 
EXCHANGE_CLASS_ID 
EXCHANGE_DECLARE_METHOD_ID 
EXCHANGE_DELETE_METHOD_ID 
EXCHANGE_QUERY_METHOD_ID 
EXCHANGE_BIND_METHOD_ID 
EXCHANGE_UNBIND_METHOD_ID 
EXCHANGE_BOUND_METHOD_ID 
QUEUE_CLASS_ID 
QUEUE_DECLARE_METHOD_ID 
QUEUE_DELETE_METHOD_ID 
QUEUE_PURGE_METHOD_ID 
QUEUE_QUERY_METHOD_ID 
FILE_CLASS_ID 
FILE_QOS_METHOD_ID 
FILE_QOS_OK_METHOD_ID 
FILE_CONSUME_METHOD_ID 
FILE_CONSUME_OK_METHOD_ID 
FILE_CANCEL_METHOD_ID 
FILE_OPEN_METHOD_ID 
FILE_OPEN_OK_METHOD_ID 
FILE_STAGE_METHOD_ID 
FILE_PUBLISH_METHOD_ID 
FILE_RETURN_METHOD_ID 
FILE_DELIVER_METHOD_ID 
FILE_ACK_METHOD_ID 
FILE_REJECT_METHOD_ID 
STREAM_CLASS_ID 
STREAM_QOS_METHOD_ID 
STREAM_QOS_OK_METHOD_ID 
STREAM_CONSUME_METHOD_ID 
STREAM_CONSUME_OK_METHOD_ID 
STREAM_CANCEL_METHOD_ID 
STREAM_PUBLISH_METHOD_ID 
STREAM_RETURN_METHOD_ID 
STREAM_DELIVER_METHOD_ID 
CLUSTER_CLASS_ID 
CLUSTER_UPDATE_REQUEST_METHOD_ID 
CLUSTER_UPDATE_OFFER_METHOD_ID 
CLUSTER_RETRACT_OFFER_METHOD_ID 
CLUSTER_READY_METHOD_ID 
CLUSTER_CONFIG_CHANGE_METHOD_ID 
CLUSTER_MESSAGE_EXPIRED_METHOD_ID 
CLUSTER_ERROR_CHECK_METHOD_ID 
CLUSTER_SHUTDOWN_METHOD_ID 
CLUSTER_CONNECTION_CLASS_ID 
CLUSTER_CONNECTION_ANNOUNCE_METHOD_ID 
CLUSTER_CONNECTION_DELIVER_CLOSE_METHOD_ID 
CLUSTER_CONNECTION_DELIVER_DO_OUTPUT_METHOD_ID 
CLUSTER_CONNECTION_ABORT_METHOD_ID 
CLUSTER_CONNECTION_CONSUMER_STATE_METHOD_ID 
CLUSTER_CONNECTION_DELIVERY_RECORD_METHOD_ID 
CLUSTER_CONNECTION_TX_START_METHOD_ID 
CLUSTER_CONNECTION_TX_ACCEPT_METHOD_ID 
CLUSTER_CONNECTION_TX_DEQUEUE_METHOD_ID 
CLUSTER_CONNECTION_TX_ENQUEUE_METHOD_ID 
CLUSTER_CONNECTION_TX_PUBLISH_METHOD_ID 
CLUSTER_CONNECTION_TX_END_METHOD_ID 
CLUSTER_CONNECTION_ACCUMULATED_ACK_METHOD_ID 
CLUSTER_CONNECTION_SESSION_STATE_METHOD_ID 
CLUSTER_CONNECTION_SHADOW_READY_METHOD_ID 
CLUSTER_CONNECTION_MEMBERSHIP_METHOD_ID 
CLUSTER_CONNECTION_RETRACT_OFFER_METHOD_ID 
CLUSTER_CONNECTION_QUEUE_POSITION_METHOD_ID 
CLUSTER_CONNECTION_EXCHANGE_METHOD_ID 
CLUSTER_CONNECTION_QUEUE_METHOD_ID 
CLUSTER_CONNECTION_EXPIRY_ID_METHOD_ID 
CLUSTER_CONNECTION_ADD_QUEUE_LISTENER_METHOD_ID 

Definition at line 34 of file constants.h.

enum qpid::framing::SegmentType

Enumerator:
SEGMENT_TYPE_CONTROL 
SEGMENT_TYPE_COMMAND 
SEGMENT_TYPE_HEADER 
SEGMENT_TYPE_BODY 

Definition at line 34 of file enum.h.

enum qpid::framing::Track

Enumerator:
TRACK_CONTROL 
TRACK_COMMAND 

Definition at line 40 of file enum.h.

enum qpid::framing::TypeCode

Enumerator:
TYPE_CODE_BIN8 
TYPE_CODE_INT8 
TYPE_CODE_UINT8 
TYPE_CODE_CHAR 
TYPE_CODE_BOOLEAN 
TYPE_CODE_BIN16 
TYPE_CODE_INT16 
TYPE_CODE_UINT16 
TYPE_CODE_BIN32 
TYPE_CODE_INT32 
TYPE_CODE_UINT32 
TYPE_CODE_FLOAT 
TYPE_CODE_CHAR_UTF32 
TYPE_CODE_BIN64 
TYPE_CODE_INT64 
TYPE_CODE_UINT64 
TYPE_CODE_DOUBLE 
TYPE_CODE_DATETIME 
TYPE_CODE_BIN128 
TYPE_CODE_UUID 
TYPE_CODE_BIN256 
TYPE_CODE_BIN512 
TYPE_CODE_BIN1024 
TYPE_CODE_VBIN8 
TYPE_CODE_STR8_LATIN 
TYPE_CODE_STR8 
TYPE_CODE_STR8_UTF16 
TYPE_CODE_VBIN16 
TYPE_CODE_STR16_LATIN 
TYPE_CODE_STR16 
TYPE_CODE_STR16_UTF16 
TYPE_CODE_VBIN32 
TYPE_CODE_MAP 
TYPE_CODE_LIST 
TYPE_CODE_ARRAY 
TYPE_CODE_STRUCT32 
TYPE_CODE_BIN40 
TYPE_CODE_DEC32 
TYPE_CODE_BIN72 
TYPE_CODE_DEC64 
TYPE_CODE_VOID 
TYPE_CODE_BIT 

Definition at line 36 of file TypeCode.h.


Function Documentation

std::ostream& qpid::framing::operator<< ( std::ostream &  ,
const Range &   
)

std::ostream& qpid::framing::operator<< ( std::ostream &  ,
const AccumulatedAck &   
)

std::ostream& qpid::framing::operator<< ( std::ostream &  out,
const AMQBody &  body 
)

std::ostream& qpid::framing::operator<< ( std::ostream &  ,
const AMQFrame &   
)

std::ostream& qpid::framing::operator<< ( std::ostream &  ,
const Buffer &   
)

template<>
bool qpid::framing::FieldValue::convertsTo< std::string > (  )  const [inline]

template<>
std::string qpid::framing::FieldValue::get< std::string > (  )  const [inline]

std::ostream& qpid::framing::operator<< ( std::ostream &  out,
const FieldValue &  v 
) [inline]

Definition at line 124 of file FieldValue.h.

References qpid::framing::FieldValue::print().

template<class T>
bool qpid::framing::getEncodedValue ( FieldTable::ValuePtr  vptr,
T &  value 
)

Definition at line 305 of file FieldValue.h.

References qpid::framing::EncodedValue< T >::getValue().

template<class Invocable>
Invoker::Result qpid::framing::invoke ( Invocable &  target,
const AMQMethodBody &  body 
)

Invoke an invocable object.

Invocable classes must provide a nested type Invoker.

Definition at line 65 of file Invoker.h.

References qpid::framing::AMQMethodBody::accept().

template<class Invocable>
Invoker::Result qpid::framing::invoke ( Invocable &  target,
const AMQBody &  body 
)

Invoke an invocable object.

Invocable classes must provide a nested type Invoker.

Definition at line 76 of file Invoker.h.

References qpid::framing::AMQMethodBody::accept(), and qpid::framing::AMQBody::getMethod().

std::ostream& qpid::framing::operator<< ( std::ostream &  o,
const framing::ProtocolInitiation &  pi 
)

std::ostream& qpid::framing::operator<< ( std::ostream &  o,
const SequenceNumber &  n 
)

std::ostream& qpid::framing::operator<< ( std::ostream &  ,
Uuid   
)

Print in format 1b4e28ba-2fa1-11d2-883f-b9a761bde3fb.

std::istream& qpid::framing::operator>> ( std::istream &  ,
Uuid &   
)

Read from format 1b4e28ba-2fa1-11d2-883f-b9a761bde3fb.

template<class Visitor, class Visitable>
Visitor::result_type qpid::framing::applyApplyVisitor ( const Visitor &  visitor,
Visitable &  visitable 
)

Convenience function to construct and apply an ApplyVisitor.

Definition at line 84 of file variant.h.

sys::ExceptionHolder qpid::framing::createSessionException ( int  code,
const std::string &  text 
)

sys::ExceptionHolder qpid::framing::createConnectionException ( int  code,
const std::string &  text 
)

sys::ExceptionHolder qpid::framing::createChannelException ( int  code,
const std::string &  text 
)

bool qpid::framing::isTypeCode ( uint8_t  t  ) 

True if t is a valid TypeCode value.

TypeCode qpid::framing::typeCode ( uint8_t   ) 

Throw exception if not a valid TypeCode.

const char* qpid::framing::typeName ( TypeCode  t  ) 

Returns:
0 if t is not a valid enum TypeCode value.

std::ostream& qpid::framing::operator<< ( std::ostream &  ,
TypeCode   
)


Variable Documentation

ProtocolVersion qpid::framing::highestProtocolVersion(0, 10) [static]

const ChannelId qpid::framing::CHANNEL_MAX = (ChannelId(~1))>>1

Maximum channel ID used by broker.

Reserve high bit for internal use.

Definition at line 52 of file amqp_types.h.

const ChannelId qpid::framing::CHANNEL_HIGH_BIT = ChannelId(~CHANNEL_MAX)

Definition at line 53 of file amqp_types.h.


Qpid C++ API Reference
Generated on Tue Dec 8 15:39:48 2009 for Qpid C++ Client API by doxygen 1.4.7