Package-level declarations

Abstract dispatcher for handling message exchanges for a specific aggregate with graceful shutdown support.

Abstract base class for message dispatchers that manage multiple aggregate dispatchers.

Represents a message dispatcher that can run and dispatch messages.

Utility object for calculating message processing parallelism.

A safe subscriber that wraps message processing with error handling.