Package-level declarations
Types
Represents a stream of command messages generated in response to a domain event in a stateless saga. This interface provides access to the commands that should be sent as part of the saga's reaction to an event.
Default implementation of CommandStream that holds a list of command messages.
Default implementation of StatelessSagaHandler that uses a filter chain for processing. This handler applies a series of filters to domain event exchanges and handles errors gracefully.
Dispatcher for stateless sagas that handles domain events and coordinates command execution. This dispatcher extends AbstractEventDispatcher to provide event-driven processing for sagas that don't maintain state between events.
A stateless saga function that processes domain events and generates command streams. This function wraps a delegate message function and extends its behavior to handle command execution and collection into a CommandStream for stateless saga processing.
Filter for stateless saga functions that applies to StatelessSagaDispatcher. This filter extends DomainEventFunctionFilter to provide filtering capabilities specific to stateless saga processing.
Registrar for stateless saga functions that creates StatelessSagaFunction instances from processors annotated with saga metadata.
Handler interface for stateless sagas that processes domain events. Implementations of this interface handle the execution of saga logic in response to domain events.