Package | Description |
---|---|
org.axonframework.auditing | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.annotation |
Classes that provide annotation support for command handling.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.commandhandling.interceptors |
Contains some useful implementations of interceptors that many application can benefit from.
|
org.axonframework.quickstart.handler | |
org.axonframework.unitofwork |
Classes in support of the UnitOfWork pattern in Axon Framework.
|
Modifier and Type | Method and Description |
---|---|
void |
AuditingUnitOfWorkListener.afterCommit(UnitOfWork unitOfWork) |
Object |
AuditingInterceptor.handle(CommandMessage<?> command,
UnitOfWork unitOfWork,
InterceptorChain chain) |
<T> EventMessage<T> |
AuditingUnitOfWorkListener.onEventRegistered(UnitOfWork unitOfWork,
EventMessage<T> event) |
void |
AuditingUnitOfWorkListener.onRollback(UnitOfWork unitOfWork,
Throwable failureCause) |
Modifier and Type | Method and Description |
---|---|
Object |
CommandHandlerInterceptor.handle(CommandMessage<?> commandMessage,
UnitOfWork unitOfWork,
InterceptorChain interceptorChain)
The handle method is invoked each time a command is dispatched through the command bus that the
CommandHandlerInterceptor is declared on.
|
Object |
CommandHandler.handle(CommandMessage<T> commandMessage,
UnitOfWork unitOfWork)
Handles the given
command . |
Constructor and Description |
---|
DefaultInterceptorChain(CommandMessage<?> command,
UnitOfWork unitOfWork,
CommandHandler<?> handler,
Iterable<? extends CommandHandlerInterceptor> chain)
Initialize the default interceptor chain to dispatch the given
command , through the
chain , to the handler . |
Modifier and Type | Method and Description |
---|---|
Object |
AnnotationCommandHandlerAdapter.handle(CommandMessage<Object> command,
UnitOfWork unitOfWork)
Invokes the @CommandHandler annotated method that accepts the given
command . |
Object |
AggregateAnnotationCommandHandler.handle(CommandMessage<Object> commandMessage,
UnitOfWork unitOfWork) |
Modifier and Type | Class and Description |
---|---|
class |
DisruptorUnitOfWork
Specialized UnitOfWork instance for the DisruptorCommandBus.
|
Modifier and Type | Method and Description |
---|---|
void |
DisruptorUnitOfWork.attachInheritedResources(UnitOfWork inheritingUnitOfWork) |
Modifier and Type | Method and Description |
---|---|
Object |
SerializationOptimizingInterceptor.handle(CommandMessage<?> commandMessage,
UnitOfWork unitOfWork,
InterceptorChain interceptorChain) |
Object |
LoggingInterceptor.handle(CommandMessage<?> command,
UnitOfWork unitOfWork,
InterceptorChain chain) |
Object |
BeanValidationInterceptor.handle(CommandMessage<?> command,
UnitOfWork unitOfWork,
InterceptorChain interceptorChain) |
Modifier and Type | Method and Description |
---|---|
Object |
CreateToDoCommandHandler.handle(CommandMessage<CreateToDoItemCommand> commandMessage,
UnitOfWork unitOfWork) |
Object |
MarkCompletedCommandHandler.handle(CommandMessage<MarkCompletedCommand> commandMessage,
UnitOfWork unitOfWork) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultUnitOfWork
Implementation of the UnitOfWork that buffers all published events until it is committed.
|
class |
NestableUnitOfWork
Abstract implementation of the UnitOfWork interface.
|
Modifier and Type | Method and Description |
---|---|
UnitOfWork |
UnitOfWorkFactory.createUnitOfWork()
Creates a new UnitOfWork instance.
|
UnitOfWork |
DefaultUnitOfWorkFactory.createUnitOfWork() |
static UnitOfWork |
CurrentUnitOfWork.get()
Gets the UnitOfWork bound to the current thread.
|
static UnitOfWork |
DefaultUnitOfWork.startAndGet()
Starts a new DefaultUnitOfWork instance, registering it a CurrentUnitOfWork.
|
static UnitOfWork |
DefaultUnitOfWork.startAndGet(TransactionManager<?> transactionManager)
Starts a new DefaultUnitOfWork instance using the given
transactionManager to provide a backing
transaction, registering it a CurrentUnitOfWork. |
Modifier and Type | Method and Description |
---|---|
void |
UnitOfWorkListenerCollection.afterCommit(UnitOfWork unitOfWork)
Invoked when the UnitOfWork is committed.
|
void |
UnitOfWorkListenerAdapter.afterCommit(UnitOfWork unitOfWork)
Invoked when the UnitOfWork is committed.
|
void |
UnitOfWorkListener.afterCommit(UnitOfWork unitOfWork)
Invoked when the UnitOfWork is committed.
|
void |
UnitOfWork.attachInheritedResources(UnitOfWork inheritingUnitOfWork)
Attach all inherited resources to the given
unitOfWork . |
void |
NestableUnitOfWork.attachInheritedResources(UnitOfWork inheritingUnitOfWork) |
static void |
CurrentUnitOfWork.clear(UnitOfWork unitOfWork)
Clears the UnitOfWork currently bound to the current thread, if that UnitOfWork is the given
unitOfWork . |
void |
UnitOfWorkListenerCollection.onCleanup(UnitOfWork unitOfWork)
Notifies listeners that the UnitOfWork is being cleaned up.
|
void |
UnitOfWorkListenerAdapter.onCleanup(UnitOfWork unitOfWork)
Notifies listeners that the UnitOfWork is being cleaned up.
|
void |
UnitOfWorkListener.onCleanup(UnitOfWork unitOfWork)
Notifies listeners that the UnitOfWork is being cleaned up.
|
<T> EventMessage<T> |
UnitOfWorkListenerCollection.onEventRegistered(UnitOfWork unitOfWork,
EventMessage<T> event)
Invoked when an Event is registered for publication when the UnitOfWork is committed.
|
<T> EventMessage<T> |
UnitOfWorkListenerAdapter.onEventRegistered(UnitOfWork unitOfWork,
EventMessage<T> event)
Invoked when an Event is registered for publication when the UnitOfWork is committed.
|
<T> EventMessage<T> |
UnitOfWorkListener.onEventRegistered(UnitOfWork unitOfWork,
EventMessage<T> event)
Invoked when an Event is registered for publication when the UnitOfWork is committed.
|
<T> EventMessage<T> |
MetaDataMutatingUnitOfWorkListenerAdapter.onEventRegistered(UnitOfWork unitOfWork,
EventMessage<T> event) |
void |
UnitOfWorkListenerCollection.onPrepareCommit(UnitOfWork unitOfWork,
Set<AggregateRoot> aggregateRoots,
List<EventMessage> events)
Invoked before aggregates are committed, and before any events are published.
|
void |
UnitOfWorkListenerAdapter.onPrepareCommit(UnitOfWork unitOfWork,
Set<AggregateRoot> aggregateRoots,
List<EventMessage> events)
Invoked before aggregates are committed, and before any events are published.
|
void |
UnitOfWorkListener.onPrepareCommit(UnitOfWork unitOfWork,
Set<AggregateRoot> aggregateRoots,
List<EventMessage> events)
Invoked before aggregates are committed, and before any events are published.
|
void |
MetaDataMutatingUnitOfWorkListenerAdapter.onPrepareCommit(UnitOfWork unitOfWork,
Set<AggregateRoot> aggregateRoots,
List<EventMessage> events) |
void |
UnitOfWorkListenerCollection.onPrepareTransactionCommit(UnitOfWork unitOfWork,
Object transaction) |
void |
UnitOfWorkListenerAdapter.onPrepareTransactionCommit(UnitOfWork unitOfWork,
Object transaction) |
void |
UnitOfWorkListener.onPrepareTransactionCommit(UnitOfWork unitOfWork,
Object transaction)
Invoked before the transaction bound to this Unit of Work is committed, but after all other commit activities
(publication of events and saving of aggregates) are performed.
|
void |
UnitOfWorkListenerCollection.onRollback(UnitOfWork unitOfWork,
Throwable failureCause)
Invoked when the UnitOfWork is rolled back.
|
void |
UnitOfWorkListenerAdapter.onRollback(UnitOfWork unitOfWork,
Throwable failureCause)
Invoked when the UnitOfWork is rolled back.
|
void |
UnitOfWorkListener.onRollback(UnitOfWork unitOfWork,
Throwable failureCause)
Invoked when the UnitOfWork is rolled back.
|
protected abstract void |
NestableUnitOfWork.registerScheduledEvents(UnitOfWork unitOfWork)
Invokes when a child Unit of Work should register its scheduled events with the given
unitOfWork . |
protected void |
DefaultUnitOfWork.registerScheduledEvents(UnitOfWork unitOfWork) |
static void |
CurrentUnitOfWork.set(UnitOfWork unitOfWork)
Binds the given
unitOfWork to the current thread. |
Copyright © 2010-2014. All Rights Reserved.