Class Summary |
AsynchronousCluster |
Cluster implementation that publishes events to the subscribed Event Listeners asynchronously from the publishing
thread. |
DefaultErrorHandler |
An ErrorHandler implementation that returns a fixed RetryPolicy instance when an error occurs. |
EventProcessor |
Scheduler that keeps track of (Event processing) tasks that need to be executed sequentially. |
EventProcessor.ProcessingResult |
Class indicating the result of Event Processing and the policy for resuming or retrying in case of errors. |
FullConcurrencyPolicy |
SequencingPolicy that does not enforce any sequencing requirements on event processing. |
RetryPolicy |
This policy tells the EventProcessor how it should deal with failed transactions. |
SequentialPerAggregatePolicy |
Concurrency policy that requires sequential processing of events raised by the same aggregate. |
SequentialPolicy |
SequencingPolicy that requires serialized handling of all events delivered to an event handler. |