Interface | Description |
---|---|
EventProcessorTask.ShutdownCallback |
Callback that allows the SequenceManager to receive a notification when this scheduler finishes processing
events.
|
SequencingPolicy<T> |
Interface to a policy definition for concurrent processing, for example event handling.
|
Class | Description |
---|---|
AsynchronousEventProcessingStrategy |
Implementation of a
EventProcessingStrategy that creates event processing tasks for asynchronous execution. |
EventProcessorTask |
Scheduler that keeps track of (Event processing) tasks that need to be executed sequentially.
|
FullConcurrencyPolicy |
SequencingPolicy that does not enforce any sequencing requirements on event processing.
|
PropertySequencingPolicy<T,K> |
A
SequencingPolicy implementation that extracts the sequence identifier from the event message payload based
on a given property or property extractor. |
PropertySequencingPolicy.Builder<T,K> |
Builder class to instantiate a
PropertySequencingPolicy . |
SequentialPerAggregatePolicy |
Concurrency policy that requires sequential processing of events raised by the same aggregate.
|
SequentialPolicy |
SequencingPolicy that requires sequential handling of all events delivered to an event handler.
|
Copyright © 2010–2023. All rights reserved.