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 acked messages (by delivery tag) |
qpid::client::AckPolicy | Policy for automatic acknowledgement of messages |
qpid::framing::AddressVisitor< R > | Convert 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 in a variant of variants |
qpid::sys::APRBase | Use of APR libraries necessitates explicit init and terminate calls |
qpid::sys::APRPool | Singleton APR memory pool |
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 type - bool 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 |
qpid::broker::BrokerAdapter | Per-channel protocol adapter |
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::amqp_0_10::CommandInvalidException | The command segments could not be decoded |
qpid::CommonOptions | Standard options for configuration |
qpid::sys::Condition | A condition variable for thread synchronization |
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::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::broker::ConnectionToken | An empty interface allowing opaque implementations of some form of token to identify a connection |
qpid::framing::Content | A representation of the AMQP 'content' data type (used for message bodies) which can hold inline data or a reference |
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::client::Exchange | DEPRECATED |
qpid::client::Execution | Provides more detailed access to the amqp 'execution layer' |
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 base exception for all field table errors |
qpid::framing::FrameDefaultVisitor | Visitor for all concrete frame body types, 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::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::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::amqp_0_10::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::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 for sent or recived through the client api |
qpid::broker::MessageDelivery | Encapsulates the different options for message delivery currently supported |
qpid::client::MessageListener | An interface through which asynchronously delivered messages can be received by an application |
qpid::client::MessageQueue | A MessageListener implementation that simply 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::sys::Mutex | Mutex lock |
qpid::framing::NoBlankVisitor< R > | Boost::static_visitor that throws exception if variant contains 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::amqp_0_10::NotAttachedDetachedException | The transport is not currently attached to any session |
qpid::amqp_0_10::NotAttachedExpiredException | The transport is not currently attached to any session |
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::broker::NullMessageStore | A null implementation of the MessageStore interface |
qpid::log::Options | Logging options for config parser |
qpid::Options | Base class for options |
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::Packer< T > | Helper to serialize packed structs |
qpid::broker::Persistable | Base class for all persistable objects |
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::broker::Prefetch | Count and total size of asynchronously delivered (i.e |
qpid::broker::PreviewSessionHandler | A SessionHandler is associated with each active channel |
qpid::broker::PreviewSessionManager | Create and manage PreviewSessionState objects |
qpid::broker::PreviewSessionManager::Observer | Observer notified of PreviewSessionManager events |
qpid::broker::PreviewSessionState | Broker-side session state includes sessions handler chains, which may themselves have state |
qpid::framing::Proxy | Base class for proxies |
ProxyConnection | A local client connection via a socket proxy |
qpid::client::Queue | DEPRECATED |
qpid::broker::Queue | The brokers representation of an amqp queue |
qpid::broker::QueueRegistry | A registry of queues indexed by queue name |
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 a copy of the frame its applied to to the specified handler |
qpid::amqp_0_10::ResourceDeletedException | A server entity the client is working with has been deleted |
qpid::amqp_0_10::ResourceLimitExceededException | The client exceeded its resource allocation |
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::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::Serializer< Derived > | Base class for all serializers |
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 >::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_99_0 | AMQP 99-0 session API |
qpid::client::Session_99_0 | AMQP 99-0 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::amqp_0_10::SessionBusyDetachedException | The session is currently attached to another transport |
qpid::amqp_0_10::SessionBusyExpiredException | The session is currently attached to another transport |
qpid::client::SessionCore | Session implementation, sets up handler chains |
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::SessionException | I have made SessionException a common base for Channel- and Connection- Exceptions |
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::broker::SessionHandler | A SessionHandler is associated with each active channel |
qpid::broker::SessionManager | Create and manage SessionState objects |
qpid::broker::SessionManager::Observer | Observer notified of SessionManager events |
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::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::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::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::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 void |
qpid::framing::Visitable< T, Base > | Base class for concrete visitable classes, implements accept() |
qpid::framing::VisitableRoot< V, R > | Root class for 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 |