AbstractAggregateEventDispatcher
Abstract base class for aggregate event dispatchers.
This class provides the foundation for dispatching domain events to appropriate handlers within an aggregate context. It manages the processing of event streams, filtering events through registered functions, and coordinating with event handlers.
Parameters
The type of message exchange being handled
See also
Inheritors
Properties
The handler responsible for processing individual events.
The registrar containing event processing functions.
The flux of message exchanges to be processed.
The level of parallelism for processing grouped exchanges.
Functions
Creates an AggregateId for this NamedAggregate with the specified parameters.
Finds the aggregate type class associated with this named aggregate.
Converts this NamedAggregate to its corresponding AggregateMetadata.
Creates a domain event exchange for the given event.
Generates a unique ID string for this NamedAggregate.
Gets the context alias prefix for this bounded context.
Handles a message exchange by processing all events in the stream.
Checks if the named aggregate is available locally at runtime.
Materializes this NamedAggregate into a MaterializedNamedAggregate.
Finds the aggregate type class associated with this named aggregate, throwing an exception if not found.
Safely processes the next message.
Handles errors that occur during message processing.
Extension function to convert a NamedAggregate to an EventNamedAggregate.
Converts the exchange to a group key for parallel processing.
Converts this NamedAggregate to its string representation.
Converts this NamedAggregate to a string representation using the context alias.