| Package | Description |
|---|---|
| org.axonframework.eventhandling.async |
| Modifier and Type | Class and Description |
|---|---|
class |
FullConcurrencyPolicy
SequencingPolicy that does not enforce any sequencing requirements on event processing.
|
class |
SequentialPerAggregatePolicy
Concurrency policy that requires sequential processing of events raised by the same aggregate.
|
class |
SequentialPolicy
SequencingPolicy that requires serialized handling of all events delivered to an event handler.
|
| Constructor and Description |
|---|
AsynchronousCluster(String identifier,
Executor executor,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Creates an AsynchronousCluster implementation using the given
executor and
sequencingPolicy. |
AsynchronousCluster(String identifier,
Executor executor,
TransactionManager transactionManager,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy)
Creates an AsynchronousCluster implementation using the given
executor,
transactionManager and sequencingPolicy. |
AsynchronousCluster(String identifier,
Executor executor,
TransactionManager transactionManager,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy,
ErrorHandler errorHandler)
Creates an AsynchronousCluster implementation using the given
executor,
transactionManager and sequencingPolicy. |
AsynchronousCluster(String name,
Executor executor,
UnitOfWorkFactory unitOfWorkFactory,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy,
ErrorHandler errorHandler)
Creates an AsynchronousCluster implementation using the given
executor,
unitOfWorkFactory and sequencingPolicy. |
AsynchronousCluster(String name,
Executor executor,
UnitOfWorkFactory unitOfWorkFactory,
SequencingPolicy<? super EventMessage<?>> sequencingPolicy,
ErrorHandler errorHandler,
OrderResolver orderResolver)
Creates an AsynchronousCluster implementation using the given
executor,
unitOfWorkFactory and sequencingPolicy. |
Copyright © 2010-2014. All Rights Reserved.