qpid::sys::AcceptEvent | Asynchronous socket accept event |
qpid::broker::AccumulatedAck | Keeps an accumulated record of acked messages (by delivery tag) |
qpid::framing::AMQRequestBody | Body of a request method frame |
qpid::framing::AMQResponseBody | Body of a response method frame |
qpid::sys::APRBase | Use of APR libraries necessitates explicit init and terminate calls |
qpid::sys::APRPool | Singleton APR memory pool |
qpid::sys::AtomicCount | Atomic counter |
qpid::broker::BasicMessage | Represents an AMQP message, i.e |
qpid::client::BasicMessageChannel | Messaging implementation using AMQP 0-8 BasicMessageChannel class to send and receiving messages |
qpid::framing::BodyHandler | Interface to handle incoming frame bodies |
qpid::broker::Broker | A broker instance |
qpid::broker::BrokerAdapter | Per-channel protocol adapter |
qpid::broker::BrokerSingleton | BrokerSingleton is a smart pointer to a process-wide singleton broker started on an os-chosen port |
qpid::client::Channel | Represents an AMQP channel, i.e |
qpid::broker::Channel | Maintains state for an AMQP channel |
qpid::framing::ChannelAdapter | Base class for client and broker channels |
qpid::client::ClientAdapter | Per-channel protocol adapter |
qpid::broker::CompletionHandler | Callback interface to handle completion of a message |
qpid::sys::Condition | A condition variable for thread synchronization |
qpid::client::Connection | Represents a connection to an AMQP broker |
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::broker::CoreRefs | A collection of references to the core objects required by an adapter, and a client proxy |
qpid::framing::Correlator | Correlate responses with actions established when sending the request |
qpid::framing::Decimal | Represents a decimal value |
qpid::broker::DeliveryRecord | Record of a delivery for which an ack is outstanding |
qpid::EmptyException | Exception to indicate empty queue or other empty state |
qpid::sys::Event | Base class for all Events |
qpid::sys::EventChannel | Channel to post and wait for events |
qpid::sys::EventChannelConnection | Implements ConnectionOutputHandler and delegates to a ConnectionInputHandler for a connection via the EventChannel |
qpid::sys::EventChannelThreads | Dynamic thread pool serving an EventChannel |
qpid::Exception | Exception base class for all Qpid exceptions |
qpid::ExceptionHolder | Holder for a heap-allocated exc eption that can be stack allocated and thrown safely |
qpid::client::Exchange | A 'handle' used to represent an AMQP exchange in the Channel methods |
qpid::framing::FieldTable | A set of name-value pairs |
qpid::broker::HandlerImpl< ProxyType > | Base template for protocol handler implementations |
qpid::client::IncomingMessage | Manage incoming messages |
qpid::client::IncomingMessage::Destination | Interface to a destination for messages |
qpid::client::IncomingMessage::Reference | Accumulate data associated with a set of messages |
qpid::client::IncomingMessage::WaitableDestination | A destination that a thread can wait on till a message arrives |
qpid::broker::InProcessBroker | A broker that implements client::Connector allowing direct in-process connection of client to broker |
qpid::broker::InProcessBroker::TaggedFrame | A frame tagged with the sender |
qpid::client::InProcessBrokerClient | An in-process client+broker all in one |
qpid::sys::LFProcessor | This class processes a poll set using the leaders-followers pattern for thread synchronization: the leader will poll and on the poll returning, it will remove a session, promote a follower to leadership, then process the session |
qpid::client::Message | A representation of messages for sent or recived through the client api |
qpid::broker::Message | Base class for all types of internal broker messages abstracting away the operations TODO; AMS: for the moment this is mostly a placeholder |
qpid::client::MessageChannel | Abstract interface for messaging implementation for a channel |
qpid::client::MessageListener | An interface through which asynchronously delivered messages can be received by an application |
qpid::client::MessageMessageChannel | Messaging implementation using AMQP 0-9 MessageMessageChannel class to send and receiving messages |
qpid::broker::MessageStore | An abstraction of the persistent storage for messages |
qpid::broker::MessageStoreModule | A null implementation of the MessageStore interface |
qpid::client::MethodBodyInstances | A list of method body instances that can be used to compare against incoming bodies |
qpid::framing::MethodContext | Invocation context for an AMQP method |
MockChannel | Combination mock OutputHandler and ChannelAdapter for tests |
MockOutputHandler | Mock output handler to collect frames |
qpid::sys::Monitor | A monitor is a condition variable and a mutex |
qpid::sys::Mutex | Mutex lock |
qpid::broker::NullMessageStore | A null implementation of the MessageStore interface |
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::sys::PODMutex | PODMutex is a POD, can be static-initialized with PODMutex m = QPID_PODMUTEX_INITIALIZER |
qpid::sys::PosixError | Exception with message from errno |
qpid::broker::Prefetch | Count and total size of asynchronously delivered (i.e |
qpid::sys::ProducerConsumer | Producer-consumer synchronisation |
qpid::sys::ProducerConsumer::ConsumerLock | Lock for code that consumes items |
qpid::sys::ProducerConsumer::Lock | Base class for producer and consumer locks |
qpid::sys::ProducerConsumer::ProducerLock | Lock for code that produces items |
qpid::framing::Proxy | Base class for proxies |
qpid::broker::Queue | The brokers representation of an amqp queue |
qpid::client::Queue | A 'handle' used to represent an AMQP queue in the Channel methods |
qpid::broker::QueueRegistry | A registry of queues indexed by queue name |
qpid::sys::ReadEvent | Asynchronous read event |
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::Reference | A reference is an accumulation point for data in a multi-frame message |
qpid::broker::ReferenceRegistry | A registry/factory for references |
qpid::framing::Requester | Manage request IDs and the response mark for locally initiated requests |
qpid::framing::Responder | Manage response ids and response mark remotely initianted requests |
qpid::client::ResponseHandler | Holds a response from the broker peer for the client |
qpid::client::ReturnedMessageHandler | An interface through which returned messages can be received by an application |
qpid::sys::Runnable | Interface for objects that can be run, e.g |
qpid::sys::ScopedDecrement< T > | Decrement counter in constructor and increment in destructor |
qpid::sys::ScopedIncrement< T > | Increment counter in constructor and decrement in destructor |
qpid::sys::ScopedLock< L > | Scoped lock template: calls lock() in ctor, unlock() in dtor |
qpid::SharedObject< T > | Template to enforce shared object conventions |
qpid::ShutdownException | Exception used to indicate that a thread should shut down |
qpid::sys::ThreadSafeQueue< T, ContainerType > | A thread safe queue template |
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::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::Value | Polymorpic base class for values |
qpid::framing::ValueOps< T > | Template for common operations on Value sub-classes |
qpid::sys::WriteEvent | Asynchronous write event |