qpid::sys::AbsTime | Class to represent an instant in time: The time resolution is in nanosecs, and this is held with 64 bits giving a total time span from about 25 million years ago to 25 million years hence |
qpid::framing::AccumulatedAck | Keeps an accumulated record of acknowledged messages (by delivery tag) |
qpid::client::AckPolicy | Policy for automatic acknowledgement of messages |
qpid::framing::AddressVisitor< R > | Convert the address of variant value to type R |
qpid::framing::AMQCommandControlBody< T > | AMQBody wrapper for Command and Control |
qpid::framing::ApplyVisitor< V > | Apply a visitor to the nested variant |
qpid::sys::APRBase | Use of APR libraries necessitates explicit init and terminate calls |
qpid::sys::APRPool | Singleton APR memory pool |
qpid::amqp_0_10::qpid::amqp_0_10::ArrayDomain< UnknownType > | A non-domain array is represented as and array of UnknownType |
qpid::sys::AtomicCount | Atomic counter |
qpid::sys::AutoShlib | A shared library handle that unloads the shlib in it's dtor |
qpid::amqp_0_10::Bit | Bit is a presence indicator - an optional value with no encoding |
qpid::framing::Blob< Size, BaseType > | A Blob is a chunk of memory which can contain a single object at a time-arbitrary type, provided sizeof(T)<=blob.size() |
qpid::sys::BlockingQueue< T > | A simple blocking queue template |
qpid::amqp_0_10::Body | Holds data from a body frame |
qpid::framing::BodyHandler | Interface to handle incoming frame bodies |
qpid::framing::BodyHolder | Holder for arbitrary frame body |
qpid::broker::Broker | A broker instance |
BrokerFixture | A fixture with an in-process broker |
qpid::broker::BrokerSingleton | BrokerSingleton is a smart pointer to a process-wide singleton broker started on an os-chosen port |
qpid::framing::Buffer::Iterator | Buffer input/output iterator |
qpid::client::Channel | THIS CLASS IS DEPRECATED AND WILL BE SHORTLY REMOVED |
qpid::framing::ChannelHandler | Sets the channel number on outgoing frames |
qpid::cluster::ClassifierHandler | Classify frames and forward to the appropriate handler |
qpid::cluster::Cluster | Connection to the cluster |
qpid::cluster::Cluster::Member | Details of a cluster member |
qpid::amqp_0_10::Codec | AMQP 0-10 encoding and decoding |
qpid::amqp_0_10::Codec::Encoder< OutIter > | Encode to an output byte iterator |
qpid::framing::CommandInvalidException | The command segments could not be decoded |
qpid::amqp_0_10::CommandInvalidException | The command segments could not be decoded |
qpid::amqp_0_10::CommmandPacker< T > | Packer for commands - serialize session.header before pack bits |
qpid::CommonOptions | Standard options for configuration |
qpid::sys::Condition | A condition variable for thread synchronization |
qpid::client::Connection | Represents a connection to an AMQP broker |
qpid::sys::ConnectionCodec | Interface of coder/decoder for a connection of a specific protocol version |
qpid::amqp_0_10::ConnectionException | Raised when the connection is unexpectedly closed |
qpid::amqp_0_10::ConnectionForcedException | An operator intervened to close the connection for some reason |
qpid::framing::ConnectionForcedException | An operator intervened to close the connection for some reason |
qpid::sys::ConnectionInputHandlerFactory | Callback interface used by the Acceptor to create a ConnectionInputHandler for each new connection |
qpid::sys::ConnectionOutputHandler | Provides the output handler associated with a connection |
qpid::client::ConnectionSettings | Used to hold seetings for a connection (and parse these from command line oprions etc as a convenience) |
qpid::broker::ConnectionToken | An empty interface allowing opaque implementations of some form of token to identify a connection |
qpid::framing::ConvertVisitor< R > | Convert the variant value to type R |
qpid::cluster::Cpg | Lightweight C++ interface to cpg.h operations |
qpid::broker::Daemon | Tools for forking and managing a daemon process |
qpid::DataDir | DataDir class |
qpid::DecoderBase< Derived > | Base class for decoders, provides generic decode functions |
qpid::sys::DeletionManager< H > | DeletionManager keeps track of handles that need to be deleted but may still be in use by one of the threads concurrently |
qpid::broker::DeliveryAdapter | The intention behind this interface is to separate the generic handling of some form of message delivery to clients that is contained in the version independent Channel class from the details required for a particular situation or version |
qpid::broker::DeliveryRecord | Record of a delivery for which an ack is outstanding |
qpid::broker::DeliveryToken | A DeliveryToken allows the delivery of a message to be associated with whatever mechanism caused it to be delivered |
qpid::cluster::Dispatchable | Interface for classes that have some "events" that need dispatching in a thread |
qpid::broker::DtxWorkRecord | Represents the work done under a particular distributed transaction across potentially multiple channels |
qpid::sys::Duration | Class to represent the duration between instants of time: As AbsTime this class also uses nanosecs for its time resolution |
qpid::EncoderBase< Derived > | Base class for encoders, provides generic encode functions |
qpid::Exception | Base class for Qpid runtime exceptions |
qpid::ExceptionHolder | Holder for exceptions |
qpid::client::Exchange | DEPRECATED |
qpid::client::Execution | Provides access to more detailed aspects of the session implementation |
qpid::broker::ExternalQueueStore | Empty class to be used by any module that wanted to set an external per queue store into persistableQueue |
qpid::framing::FieldTable | A set of name-value pairs |
qpid::framing::FieldValue | Value that can appear in an AMQP field table |
qpid::framing::FieldValueException | Exception that is the base exception for all field table errors |
qpid::framing::FrameDefaultVisitor | Visitor for all concrete frame body types, which combines AMQBodyConstVisitor and MethodBodyDefaultVisitor |
qpid::framing::FrameSet | Collects the frames representing a message |
qpid::amqp_0_10::FramingErrorException | A valid frame header cannot be formed from the incoming byte stream |
qpid::framing::FramingErrorException | A valid frame header cannot be formed from the incoming byte stream |
qpid::framing::Handler< T > | Generic handler that can be linked into chains |
qpid::framing::Handler< T >::Chain | A Chain is a handler that forwards to a modifiable linked list of handlers |
qpid::framing::Handler< T >::Chains | In/out pair of handler chains |
qpid::framing::Handler< T >::Functor< F > | Adapt any void(T) functor as a Handler |
qpid::framing::Handler< T >::InOutHandler | Support for implementing an in-out handler pair as a single class |
qpid::framing::Handler< T >::InOutHandlerInterface | Interface for a handler that implements a pair of in/out handle operations |
qpid::framing::Handler< T >::MemFunRef< X, F > | Adapt a member function of X as a Handler |
qpid::broker::HandlerImpl | Base template for protocol handler implementations |
qpid::IList< Node > | Intrusive doubly-linked list |
qpid::IListNode< Pointer > | Base class for values (nodes) in an IList |
qpid::amqp_0_10::IllegalArgumentException | The command argument is malformed, i.e |
qpid::framing::IllegalArgumentException | The command argument is malformed, i.e |
qpid::framing::IllegalStateException | The peer sent a command that is not permitted in the current state of the session |
qpid::amqp_0_10::IllegalStateException | The peer sent a command that is not permitted in the current state of the session |
qpid::InlineAllocator< BaseAllocator, Max > | An allocator that has inline storage for up to Max objects of type BaseAllocator::value_type |
qpid::InlineVector< T, Max, Alloc > | A vector that stores up to Max elements in inline storage, otherwise uses normal vector allocation |
qpid::amqp_0_10::InternalErrorException | The peer could not complete the command because of an internal error |
qpid::framing::InternalErrorException | The peer could not complete the command because of an internal error |
qpid::amqp_0_10::InvalidArgumentException | An invalid argument was passed to a command, and the operation could not proceed |
qpid::framing::InvalidArgumentException | An invalid argument was passed to a command, and the operation could not proceed |
qpid::framing::InvalidConversionException | Exception thrown when we can't perform requested conversion |
qpid::amqp_0_10::InvalidPathException | The client tried to work with an unknown virtual host |
qpid::framing::InvalidPathException | The client tried to work with an unknown virtual host |
qpid::framing::Invoker | Base class for invoker visitors |
qpid::ISList< Node > | Intrusive singly-linked list |
qpid::ISListNode< Pointer > | Base class for values (nodes) in an ISList |
qpid::client::LocalQueue | Local representation of a remote queue |
qpid::log::Logger | Central logging agent |
qpid::log::Logger::Output | Interface for log output destination |
qpid::client::Message | A representation of messages sent or received through the client api |
qpid::broker::MessageDelivery | TODO: clean this up; we don't need it anymore in its current form |
qpid::client::MessageListener | An interface through which asynchronously delivered messages can be received by an application |
qpid::client::MessageQueue | A MessageListener implementation that queues up messages |
qpid::broker::MessageStore | An abstraction of the persistent storage for messages |
qpid::broker::MessageStoreModule | A null implementation of the MessageStore interface |
qpid::sys::Monitor | A monitor is a condition variable and a mutex |
qpid::Msg | A simple wrapper for std::ostringstream that allows in place construction of a message and automatic conversion to string |
qpid::sys::Mutex | Mutex lock |
qpid::framing::NoBlankVisitor< R > | Boost::static_visitor that throws an exception if variant contains a blank |
qpid::amqp_0_10::NormalDetachedException | The session was detached by request |
qpid::amqp_0_10::NormalException | The connection closed normally |
qpid::amqp_0_10::NormalExpiredException | The session was detached by request |
qpid::amqp_0_10::NotAllowedException | The peer tried to use a command a manner that is inconsistent with the rules described in the specification |
qpid::framing::NotAllowedException | The peer tried to use a command a manner that is inconsistent with the rules described in the specification |
qpid::amqp_0_10::NotAttachedDetachedException | The transport is not currently attached to any session |
qpid::framing::NotAttachedException | The transport is not currently attached to any session |
qpid::amqp_0_10::NotAttachedExpiredException | The transport is not currently attached to any session |
qpid::framing::NotFoundException | The client attempted to work with a server entity that does not exist |
qpid::amqp_0_10::NotFoundException | The client attempted to work with a server entity that does not exist |
qpid::amqp_0_10::NotImplementedException | The peer tried to use functionality that is not implemented in its partner |
qpid::framing::NotImplementedException | The peer tried to use functionality that is not implemented in its partner |
qpid::broker::NullMessageStore | A null implementation of the MessageStore interface |
qpid::Options | Base class for options |
qpid::log::Options | Logging options for config parser |
qpid::amqp_0_10::PackBits | "Encoder" that encodes a struct as a set of bit flags for all non-empty members |
qpid::amqp_0_10::PackedDecoder< Decoder, Bits > | Decode members enabled by Bits |
qpid::amqp_0_10::Packer< T > | Helper to serialize packed structs |
qpid::broker::Persistable | Base class for all persistable objects |
qpid::broker::PersistableConfig | The interface used by general-purpose persistable configuration for the message store |
qpid::broker::PersistableExchange | The interface exchanges must expose to the MessageStore in order to be persistable |
qpid::broker::PersistableMessage | The interface messages must expose to the MessageStore in order to be persistable |
qpid::broker::PersistableQueue | The interface queues must expose to the MessageStore in order to be persistable |
qpid::Plugin | Plug-in base class |
qpid::Plugin::Target | Base interface for targets that receive plug-ins |
qpid::sys::PODMutex | PODMutex is a POD, can be static-initialized with PODMutex m = QPID_PODMUTEX_INITIALIZER |
qpid::amqp_0_10::PreconditionFailedException | The client requested a command that was not allowed because some precondition failed |
qpid::framing::PreconditionFailedException | The client requested a command that was not allowed because some precondition failed |
qpid::broker::Prefetch | Count and total size of asynchronously delivered (i.e |
qpid::framing::Proxy | Base class for proxies |
ProxyConnection | A local client connection via a socket proxy |
qpid::broker::Queue | The brokers representation of an amqp queue |
qpid::client::Queue | DEPRECATED |
qpid::broker::QueueRegistry | A registry of queues indexed by queue name |
qpid::Range< T > | A range of values, used in RangeSet |
qpid::RangeSet< T > | A set implemented as a list of [begin, end) ranges |
qpid::broker::RecoverableConfig | The interface through which configurations are recovered |
qpid::broker::RecoverableExchange | The interface through which bindings are recovered |
qpid::broker::RecoverableMessage | The interface through which messages are reloaded on recovery |
qpid::broker::RecoverableQueue | The interface through which messages are added back to queues on recovery |
qpid::broker::RecoverableTransaction | The interface through which prepared 2pc transactions are recovered |
qpid::RefCounted | Reference-counted base class |
qpid::RefCountedChild | Reference-counted member of a reference-counted parent class |
qpid::framing::Relay | Sends to the specified handler a copy of the frame it is applied to |
qpid::amqp_0_10::ResourceDeletedException | A server entity the client is working with has been deleted |
qpid::framing::ResourceDeletedException | A server entity the client is working with has been deleted |
qpid::framing::ResourceLimitExceededException | The client exceeded its resource allocation |
qpid::amqp_0_10::ResourceLimitExceededException | The client exceeded its resource allocation |
qpid::framing::ResourceLockedException | The client attempted to work with a server entity to which it has no access because another client is working with it |
qpid::amqp_0_10::ResourceLockedException | The client attempted to work with a server entity to which it has no access because another client is working with it |
qpid::sys::Runnable | Interface for objects that can be run, e.g |
qpid::sys::RWlock | RW lock |
qpid::sys::ScopedDecrement< T > | Decrement counter in constructor and increment in destructor |
qpid::sys::ScopedIncrement< T, F > | Increment counter in constructor and decrement in destructor |
qpid::sys::ScopedLock< L > | Scoped lock template: calls lock() in ctor, unlock() in dtor |
qpid::log::Selector | A selector identifies the set of log messages to enable |
qpid::broker::SemanticState | SemanticState holds the L3 and L4 state of an open session, whether attached to a channel or suspended |
qpid::framing::SendContent | Functor that sends frame to handler, refragmenting if necessary |
qpid::framing::SequenceNumber | 4-byte sequence number that 'wraps around' |
qpid::amqp_0_10::SerializableOptional< T > | Serialization for optional values |
qpid::SerializablePair< T, U > | Serialize std::pair |
qpid::amqp_0_10::SerializableString< T, SizeType, Unique > | Template for length-prefixed strings/arrays |
qpid::SerializeAs< Type, AsType > | Serialize a type by converting it to/from another type |
qpid::framing::SerializeHandler< T > | Serializer that can be inserted into a Handler chain |
qpid::sys::Serializer< Task > | Execute tasks sequentially, queuing tasks when necessary to ensure only one thread at a time executes a task and tasks are executed in order |
qpid::Serializer< Derived > | Base class for all serializers |
qpid::Serializer< Derived >::Ref< S > | Wrapper functor to pass serializer functors by reference |
qpid::Serializer< Derived >::ScopedLimit | Temporarily set a lower relative limit on the serializer |
qpid::sys::SerializerBase | Abstract base class for Serializer below |
qpid::client::no_keyword::Session_0_10 | AMQP 0-10 session API |
qpid::client::Session_0_10 | AMQP 0-10 session API with keyword arguments |
qpid::amqp_0_10::SessionAbortedException | Raised when a session is destroyed due to an execution.exception |
qpid::broker::SessionAdapter | Per-channel protocol adapter |
qpid::client::SessionBase | Basic session operations that are not derived from AMQP XML methods |
qpid::client::SessionBase::ScopedSync | Instances of this class turn synchronous mode on for the duration of their scope (and revert back to async if required afterwards) |
qpid::amqp_0_10::SessionBusyDetachedException | The session is currently attached to another transport |
qpid::framing::SessionBusyException | The session is currently attached to another transport |
qpid::amqp_0_10::SessionBusyExpiredException | The session is currently attached to another transport |
qpid::amqp_0_10::SessionDestroyedException | Raised when the state of a session has been destroyed |
qpid::amqp_0_10::SessionDetachedException | Raised when a session with non-0 timeout is unexpectedly detached or if an attempt is made to use a session that is not attached |
qpid::amqp_0_10::SessionException | Raised when a session is unexpectedly detached for any reason, or if an attempt is made to use a session that is not attached |
qpid::amqp_0_10::SessionExpiredException | Raised when a session with 0 timeout is unexpectedly detached and therefore expires and is destroyed |
SessionFixtureT< ConnectionType > | A BrokerFixture with open Connection, Session and SubscriptionManager and LocalQueue for convenience |
qpid::amqp_0_10::SessionHandler | Base SessionHandler with logic common to both client and broker |
qpid::broker::SessionHandler | A SessionHandler is associated with each active channel |
qpid::SessionId | Identifier for a session |
qpid::broker::SessionManager | Create and manage SessionState objects |
qpid::broker::SessionManager::Observer | Observer notified of SessionManager events |
qpid::SessionPoint | A point in the session |
qpid::SessionState | Support for session idempotence barrier and resume as defined in AMQP 0-10 |
qpid::framing::SessionState | Session state common to client and broker |
qpid::broker::SessionState | Broker-side session state includes sessions handler chains, which may themselves have state |
qpid::SessionState::ReceiveState | State for commands received |
qpid::SessionState::SendState | State for commands sent |
qpid::SharedObject< T > | Template to enforce shared object conventions |
qpid::sys::Shlib | Encapsulates a shared library handle |
SocketProxy | A simple socket proxy that forwards to another socket |
qpid::log::Statement | POD struct representing a logging statement in source code |
qpid::sys::StateMonitor< Enum, MaxEnum > | A monitor with an enum state value |
qpid::client::SubscriptionManager | Utility to assist with creating subscriptions |
qpid::sys::SystemInfo | Retrieve information about the system we are running on |
qpid::TcpAddress | TCP address of a broker - host:port |
qpid::TestCase | Interface to be implemented by test cases for use with the test runner |
qpid::broker::Tokens | A vector of string tokens |
qpid::broker::TopicPattern | Tokens that have been normalized as a pattern and can be matched with topic Tokens |
qpid::amqp_0_10::TransportBusyDetachedException | The transport is currently attached to another session |
qpid::framing::TransportBusyException | The transport is currently attached to another session |
qpid::amqp_0_10::TransportBusyExpiredException | The transport is currently attached to another session |
qpid::broker::TxAccept | Defines the transactional behaviour for accepts received by a transactional channel |
qpid::broker::TxAck | Defines the transactional behaviour for acks received by a transactional channel |
qpid::broker::TxPublish | Defines the behaviour for publish operations on a transactional channel |
qpid::framing::typed_in_place_factory0< T > | 0-arg typed_in_place_factory, missing in boost |
qpid::framing::TypeFilter< Type > | Predicate that selects frames by type |
qpid::framing::UnauthorizedAccessException | The client attempted to work with a server entity to which it has no access due to security settings |
qpid::amqp_0_10::UnauthorizedAccessException | The client attempted to work with a server entity to which it has no access due to security settings |
qpid::amqp_0_10::Unit | A Unit contains a frame header and associated value |
qpid::amqp_0_10::UnknownIdsDetachedException | Command data was received prior to any use of the command-point control |
qpid::framing::UnknownIdsException | Command data was received prior to any use of the command-point control |
qpid::amqp_0_10::UnknownIdsExpiredException | Command data was received prior to any use of the command-point control |
qpid::amqp_0_10::UnknownType | Encode/decode an unknown type based on typecode |
qpid::Url | An AMQP URL contains a list of addresses |
qpid::framing::Uuid | A UUID is represented as a boost::array of 16 bytes |
qpid::framing::Visit< T, R > | Visit() interface for type T (optional return type R, default is void |
qpid::framing::Visitable< T, Base > | The base class for concrete visitable classes |
qpid::framing::VisitableRoot< V, R > | The root class for the hierarchy of objects visitable by Visitor V |
qpid::amqp_0_10::Void | Void type |
qpid::sys::Waitable | A monitor that keeps track of waiting threads |
qpid::sys::Waitable::ScopedWait | Use this inside a scoped lock around the call to Monitor::wait to be counted as a waiter |
qpid::amqp_0_10::Wrapper< T, Unique > | Wrapper that behaves like type T but is a distinct type for overloading purposes |