A registry of subscription by session that allows looking up subscriptions.
Abstract base class for a
MessageHandler that broker messages to
Abstract base class for implementations of
looks up information in messages but delegates to abstract methods for the
actual storage and retrieval.
Event raised when a broker's availability changes.
Decorator for an
ExecutorSubscribableChannel that ensures messages
are processed in the order they were published to the channel.