Provides a "simple" message broker implementation along with an abstract base class and other supporting types such as a registry for subscriptions.
ClassDescriptionAbstract base class for a
MessageHandlerthat broker messages to registered subscribers.Abstract base class for implementations of
SubscriptionRegistrythat 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
ExecutorSubscribableChannelthat ensures messages are processed in the order they were published to the channel.A registry of subscription by session that allows looking up subscriptions.