Uses of Interface
org.axonframework.messaging.unitofwork.UnitOfWork

Packages that use UnitOfWork

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.unitofwork
org.axonframework.modelling.command
org.axonframework.modelling.command.inspection
org.axonframework.modelling.saga.repository

Uses of UnitOfWork in org.axonframework.disruptor.commandhandling

Classes in org.axonframework.disruptor.commandhandling that implement UnitOfWork

Modifier and Type	Class and Description
class	CommandHandlingEntry DataHolder for the DisruptorCommandBus.
class	DisruptorUnitOfWork<T extends Message<?>> Specialized UnitOfWork instance for the DisruptorCommandBus.

Methods in org.axonframework.disruptor.commandhandling that return UnitOfWork

Modifier and Type	Method and Description
UnitOfWork<T>	DisruptorUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)

Methods in org.axonframework.disruptor.commandhandling that return types with arguments of type UnitOfWork

Modifier and Type	Method and Description
Optional<UnitOfWork<?>>	DisruptorUnitOfWork.parent()

Method parameters in org.axonframework.disruptor.commandhandling with type arguments of type UnitOfWork

Modifier and Type	Method and Description
protected void	DisruptorUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler)

Uses of UnitOfWork in org.axonframework.eventhandling

Methods in org.axonframework.eventhandling with parameters of type UnitOfWork

Modifier and Type	Method and Description
protected void	AbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork, Segment segment) Process a batch of events.

Uses of UnitOfWork in org.axonframework.messaging

Methods in org.axonframework.messaging with parameters of type UnitOfWork

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.

Constructors in org.axonframework.messaging with parameters of type UnitOfWork

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.

Uses of UnitOfWork in org.axonframework.messaging.interceptors

Methods in org.axonframework.messaging.interceptors with parameters of type UnitOfWork

Modifier and Type	Method and Description
Object	BeanValidationInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain)
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)

Uses of UnitOfWork in org.axonframework.messaging.unitofwork

Classes in org.axonframework.messaging.unitofwork that implement UnitOfWork

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.

Methods in org.axonframework.messaging.unitofwork that return UnitOfWork

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>	DefaultUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)
UnitOfWork<T>	BatchingUnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator)
UnitOfWork<T>	UnitOfWork.transformMessage(Function<T,? extends Message<?>> transformOperator) Transform the Message being processed using the given operator and stores the result.

Methods in org.axonframework.messaging.unitofwork that return types with arguments of type UnitOfWork

Modifier and Type	Method and Description
Optional<UnitOfWork<?>>	AbstractUnitOfWork.parent()
Optional<UnitOfWork<?>>	UnitOfWork.parent() Returns an optional for the parent of this Unit of Work.

Methods in org.axonframework.messaging.unitofwork with parameters of type UnitOfWork

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.

Method parameters in org.axonframework.messaging.unitofwork with type arguments of type UnitOfWork

Modifier and Type	Method and Description
protected abstract void	AbstractUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) Register the given handler with the Unit of Work.
protected void	DefaultUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler)
protected void	BatchingUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler)
void	MessageProcessingContext.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) Adds a handler to the collection.
void	AbstractUnitOfWork.afterCommit(Consumer<UnitOfWork<T>> handler)
void	UnitOfWork.afterCommit(Consumer<UnitOfWork<T>> handler) Register given handler with the Unit of Work.
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	AbstractUnitOfWork.onCleanup(Consumer<UnitOfWork<T>> handler)
void	UnitOfWork.onCleanup(Consumer<UnitOfWork<T>> handler) Register given handler with the Unit of Work.
void	AbstractUnitOfWork.onCommit(Consumer<UnitOfWork<T>> handler)
void	UnitOfWork.onCommit(Consumer<UnitOfWork<T>> handler) Register given handler with the Unit of Work.
void	AbstractUnitOfWork.onPrepareCommit(Consumer<UnitOfWork<T>> handler)
void	UnitOfWork.onPrepareCommit(Consumer<UnitOfWork<T>> handler) Register given handler with the Unit of Work.
void	AbstractUnitOfWork.onRollback(Consumer<UnitOfWork<T>> handler)
void	UnitOfWork.onRollback(Consumer<UnitOfWork<T>> handler) Register given handler with the Unit of Work.

Uses of UnitOfWork in org.axonframework.modelling.command

Methods in org.axonframework.modelling.command with parameters of type UnitOfWork

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.

Uses of UnitOfWork in org.axonframework.modelling.command.inspection

Methods in org.axonframework.modelling.command.inspection with parameters of type UnitOfWork

Modifier and Type	Method and Description
Object	AnnotatedCommandHandlerInterceptor.handle(UnitOfWork<? extends CommandMessage<?>> unitOfWork, InterceptorChain interceptorChain)

Uses of UnitOfWork in org.axonframework.modelling.saga.repository

Methods in org.axonframework.modelling.saga.repository with parameters of type UnitOfWork

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.