Package | Description |
---|---|
org.axonframework.disruptor.commandhandling | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.messaging.interceptors | |
org.axonframework.messaging.interceptors.legacyvalidation | |
org.axonframework.messaging.unitofwork | |
org.axonframework.modelling.command | |
org.axonframework.modelling.command.inspection | |
org.axonframework.modelling.saga.repository |
Modifier and Type | Class and Description |
---|---|
class |
CommandHandlingEntry
DataHolder for the DisruptorCommandBus.
|
class |
DisruptorUnitOfWork<T extends Message<?>>
Specialized UnitOfWork instance for the
DisruptorCommandBus . |
Modifier and Type | Method and Description |
---|---|
UnitOfWork<T> |
DisruptorUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator) |
Modifier and Type | Method and Description |
---|---|
Optional<UnitOfWork<?>> |
DisruptorUnitOfWork.parent() |
Modifier and Type | Method and Description |
---|---|
protected void |
DisruptorUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages,
UnitOfWork<? extends EventMessage<?>> unitOfWork)
Process a batch of events.
|
protected void |
AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages,
UnitOfWork<? extends EventMessage<?>> unitOfWork,
Collection<Segment> processingSegments)
Process a batch of events.
|
Modifier and Type | Method and Description |
---|---|
Object |
MessageHandlerInterceptor.handle(UnitOfWork<? extends T> unitOfWork,
InterceptorChain interceptorChain)
Invoked before a Message is handled by a designated
MessageHandler . |
Constructor and Description |
---|
DefaultInterceptorChain(UnitOfWork<? extends T> unitOfWork,
Iterable<? extends MessageHandlerInterceptor<? super T>> interceptors,
MessageHandler<? super T> handler)
Initialize the default interceptor chain to dispatch the given
message , through the
chain , to the handler . |
Modifier and Type | Method and Description |
---|---|
Object |
TransactionManagingInterceptor.handle(UnitOfWork<? extends T> unitOfWork,
InterceptorChain interceptorChain) |
Object |
LoggingInterceptor.handle(UnitOfWork<? extends T> unitOfWork,
InterceptorChain interceptorChain) |
Object |
CorrelationDataInterceptor.handle(UnitOfWork<? extends T> unitOfWork,
InterceptorChain interceptorChain) |
Object |
BeanValidationInterceptor.handle(UnitOfWork<? extends T> unitOfWork,
InterceptorChain interceptorChain) |
Modifier and Type | Method and Description |
---|---|
Object |
BeanValidationInterceptor.handle(UnitOfWork<? extends T> unitOfWork,
InterceptorChain interceptorChain)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractUnitOfWork<T extends Message<?>>
Abstract implementation of the Unit of Work.
|
class |
BatchingUnitOfWork<T extends Message<?>>
Unit of Work implementation that is able to process a batch of Messages instead of just a single Message.
|
class |
DefaultUnitOfWork<T extends Message<?>>
Implementation of the UnitOfWork that processes a single message.
|
Modifier and Type | Method and Description |
---|---|
static UnitOfWork<?> |
CurrentUnitOfWork.get()
Gets the UnitOfWork bound to the current thread.
|
default UnitOfWork<?> |
UnitOfWork.root()
Returns the root of this Unit of Work.
|
UnitOfWork<T> |
UnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)
Transform the Message being processed using the given operator and stores the result.
|
UnitOfWork<T> |
DefaultUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator) |
UnitOfWork<T> |
BatchingUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator) |
Modifier and Type | Method and Description |
---|---|
Optional<UnitOfWork<?>> |
UnitOfWork.parent()
Returns an optional for the parent of this Unit of Work.
|
Optional<UnitOfWork<?>> |
AbstractUnitOfWork.parent() |
Modifier and Type | Method and Description |
---|---|
static void |
CurrentUnitOfWork.clear(UnitOfWork<?> unitOfWork)
Clears the UnitOfWork currently bound to the current thread, if that UnitOfWork is the given
unitOfWork . |
void |
MessageProcessingContext.notifyHandlers(UnitOfWork<T> unitOfWork,
UnitOfWork.Phase phase)
Invoke the handlers in this collection attached to the given
phase . |
static void |
CurrentUnitOfWork.set(UnitOfWork<?> unitOfWork)
Binds the given
unitOfWork to the current thread. |
Modifier and Type | Method and Description |
---|---|
void |
MessageProcessingContext.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler)
Adds a handler to the collection.
|
protected void |
DefaultUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler) |
protected void |
BatchingUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler) |
protected abstract void |
AbstractUnitOfWork.addHandler(UnitOfWork.Phase phase,
Consumer<UnitOfWork<T>> handler)
Register the given
handler with the Unit of Work. |
void |
UnitOfWork.afterCommit(Consumer<UnitOfWork<T>> handler)
Register given
handler with the Unit of Work. |
void |
AbstractUnitOfWork.afterCommit(Consumer<UnitOfWork<T>> handler) |
static boolean |
CurrentUnitOfWork.ifStarted(Consumer<UnitOfWork<?>> consumer)
If a UnitOfWork is started, invokes the given
consumer with the active Unit of Work. |
static <T> Optional<T> |
CurrentUnitOfWork.map(Function<UnitOfWork<?>,T> function)
If a Unit of Work is started, execute the given
function on it. |
void |
UnitOfWork.onCleanup(Consumer<UnitOfWork<T>> handler)
Register given
handler with the Unit of Work. |
void |
AbstractUnitOfWork.onCleanup(Consumer<UnitOfWork<T>> handler) |
void |
UnitOfWork.onCommit(Consumer<UnitOfWork<T>> handler)
Register given
handler with the Unit of Work. |
void |
AbstractUnitOfWork.onCommit(Consumer<UnitOfWork<T>> handler) |
void |
UnitOfWork.onPrepareCommit(Consumer<UnitOfWork<T>> handler)
Register given
handler with the Unit of Work. |
void |
AbstractUnitOfWork.onPrepareCommit(Consumer<UnitOfWork<T>> handler) |
void |
UnitOfWork.onRollback(Consumer<UnitOfWork<T>> handler)
Register given
handler with the Unit of Work. |
void |
AbstractUnitOfWork.onRollback(Consumer<UnitOfWork<T>> handler) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,A> |
AbstractRepository.managedAggregates(UnitOfWork<?> uow)
Returns the map of aggregates currently managed by this repository under the given unit of work.
|
Modifier and Type | Method and Description |
---|---|
Object |
AnnotatedCommandHandlerInterceptor.handle(UnitOfWork<? extends CommandMessage<?>> unitOfWork,
InterceptorChain interceptorChain) |
Modifier and Type | Method and Description |
---|---|
protected Set<String> |
AnnotatedSagaRepository.unsavedSagaResource(UnitOfWork<?> unitOfWork)
Returns a set of identifiers of sagas that may have changed in the context of the given
unitOfWork and
have not been saved yet. |
Copyright © 2010–2024. All rights reserved.