An object which produces deliveries to which allows new DeliveryConsumer object to bind so they can also receive those deliveries.
A Broker is parent object of all services assoicated with the serverside of a message passing system.
Defines an interface to access and update persistent broker configurations.
The delivery consumer accepts messages from a delivery producer.
A producer which sends Delivery objects to a delivery consumer.
Before a delivery producer can send Delivery objects to a delivery consumer, it creates a Delivery session which it uses to send the deliveries over.
A simple ConfigStore implementation which only support one broker configuration stored in an XML file.
Provides a non-blocking concurrent producer to consumer routing implementation.
LocalTransaction
Abstracts wire protocol message implementations.
A sink that allows the downstream sink to set to an optional sink.
Implements a delivery sink which buffers the overflow of deliveries that a 'down stream' sink cannot accept when it's full.
A delivery sink which buffers deliveries sent to it up to it's maxSize settings after which it starts flow controlling the sender.
tracks one producer to consumer session / credit window.
Defines a simple trait to control the flow of data between callers and implementations of this trait.
A SinkMux multiplexes access to a target sink so that multiple producers can send data to it concurrently.
A sizer can determine the size of other objects.
Interfaces a DispatchConsumer with a Queue.
A logical messaging topic
Keeps track of all the actions the need to be done when a transaction does a commit or rollback.
A delivery sink which is connected to a transport.
XATransaction
The BrokerFactory creates Broker objects from a URI.
A new Delivery object is created every time a message is transfered between a producer and it's consumer or consumers.