Package-level declarations
Types
Link copied to clipboard
abstract class AggregateDispatcher<T : MessageExchange<*, *>> : SafeSubscriber<Void> , MessageDispatcher, ParallelismCapable, NamedAggregateDecorator, TerminatedSignalCapable<Void>
Abstract dispatcher for handling message exchanges for a specific aggregate with graceful shutdown support.
Link copied to clipboard
Abstract base class for message dispatchers that manage multiple aggregate dispatchers.
Link copied to clipboard
Represents a message dispatcher that can run and dispatch messages.
Link copied to clipboard
object MessageParallelism
Utility object for calculating message processing parallelism.
Link copied to clipboard
interface ParallelismCapable
Link copied to clipboard
A safe subscriber that wraps message processing with error handling.