Uses of Interface
org.axonframework.messaging.unitofwork.UnitOfWork
Packages that use UnitOfWork
Package
Description
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus.Classes related to message processing in Axon Framework.
-
Uses of UnitOfWork in org.axonframework.disruptor.commandhandling
Classes in org.axonframework.disruptor.commandhandling that implement UnitOfWorkModifier and TypeClassDescriptionclassDataHolder for the DisruptorCommandBus.classDisruptorUnitOfWork<T extends Message<?>>Specialized UnitOfWork instance for theDisruptorCommandBus.Methods in org.axonframework.disruptor.commandhandling that return UnitOfWorkModifier and TypeMethodDescriptionDisruptorUnitOfWork.transformMessage(Function<T, ? extends Message<?>> transformOperator) Methods in org.axonframework.disruptor.commandhandling that return types with arguments of type UnitOfWorkMethod parameters in org.axonframework.disruptor.commandhandling with type arguments of type UnitOfWorkModifier and TypeMethodDescriptionprotected voidDisruptorUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) -
Uses of UnitOfWork in org.axonframework.eventhandling
Methods in org.axonframework.eventhandling with parameters of type UnitOfWorkModifier and TypeMethodDescriptionprotected final voidAbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork) Process a batch of events.protected voidAbstractEventProcessor.processInUnitOfWork(List<? extends EventMessage<?>> eventMessages, UnitOfWork<? extends EventMessage<?>> unitOfWork, Collection<Segment> processingSegments) Process a batch of events. -
Uses of UnitOfWork in org.axonframework.messaging
Methods in org.axonframework.messaging with parameters of type UnitOfWorkModifier and TypeMethodDescriptionMessageHandlerInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain) Invoked before a Message is handled by a designatedMessageHandler.Constructors in org.axonframework.messaging with parameters of type UnitOfWorkModifierConstructorDescriptionDefaultInterceptorChain(UnitOfWork<? extends T> unitOfWork, Iterable<? extends MessageHandlerInterceptor<? super T>> interceptors, MessageHandler<? super T> handler) Initialize the default interceptor chain to dispatch the givenmessage, through thechain, to thehandler. -
Uses of UnitOfWork in org.axonframework.messaging.interceptors
Methods in org.axonframework.messaging.interceptors with parameters of type UnitOfWorkModifier and TypeMethodDescriptionBeanValidationInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain) CorrelationDataInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain) LoggingInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain) TransactionManagingInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain) -
Uses of UnitOfWork in org.axonframework.messaging.interceptors.legacyvalidation
Methods in org.axonframework.messaging.interceptors.legacyvalidation with parameters of type UnitOfWorkModifier and TypeMethodDescriptionBeanValidationInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain) Deprecated. -
Uses of UnitOfWork in org.axonframework.messaging.timeout
Methods in org.axonframework.messaging.timeout with parameters of type UnitOfWorkModifier and TypeMethodDescriptionUnitOfWorkTimeoutInterceptor.handle(UnitOfWork<? extends Message<?>> unitOfWork, InterceptorChain interceptorChain) -
Uses of UnitOfWork in org.axonframework.messaging.unitofwork
Classes in org.axonframework.messaging.unitofwork that implement UnitOfWorkModifier and TypeClassDescriptionclassAbstractUnitOfWork<T extends Message<?>>Abstract implementation of the Unit of Work.classBatchingUnitOfWork<T extends Message<?>>Unit of Work implementation that is able to process a batch of Messages instead of just a single Message.classDefaultUnitOfWork<T extends Message<?>>Implementation of the UnitOfWork that processes a single message.Methods in org.axonframework.messaging.unitofwork that return UnitOfWorkModifier and TypeMethodDescriptionstatic UnitOfWork<?> CurrentUnitOfWork.get()Gets the UnitOfWork bound to the current thread.default UnitOfWork<?> UnitOfWork.root()Returns the root of this Unit of Work.BatchingUnitOfWork.transformMessage(Function<T, ? extends Message<?>> transformOperator) DefaultUnitOfWork.transformMessage(Function<T, ? extends Message<?>> transformOperator) 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 UnitOfWorkModifier and TypeMethodDescriptionOptional<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 UnitOfWorkModifier and TypeMethodDescriptionstatic voidCurrentUnitOfWork.clear(UnitOfWork<?> unitOfWork) Clears the UnitOfWork currently bound to the current thread, if that UnitOfWork is the givenunitOfWork.voidMessageProcessingContext.notifyHandlers(UnitOfWork<T> unitOfWork, UnitOfWork.Phase phase) Invoke the handlers in this collection attached to the givenphase.static voidCurrentUnitOfWork.set(UnitOfWork<?> unitOfWork) Binds the givenunitOfWorkto the current thread.Method parameters in org.axonframework.messaging.unitofwork with type arguments of type UnitOfWorkModifier and TypeMethodDescriptionprotected abstract voidAbstractUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) Register the givenhandlerwith the Unit of Work.protected voidBatchingUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) protected voidDefaultUnitOfWork.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) voidMessageProcessingContext.addHandler(UnitOfWork.Phase phase, Consumer<UnitOfWork<T>> handler) Adds a handler to the collection.voidAbstractUnitOfWork.afterCommit(Consumer<UnitOfWork<T>> handler) voidUnitOfWork.afterCommit(Consumer<UnitOfWork<T>> handler) Register givenhandlerwith the Unit of Work.static booleanCurrentUnitOfWork.ifStarted(Consumer<UnitOfWork<?>> consumer) If a UnitOfWork is started, invokes the givenconsumerwith the active Unit of Work.static <T> Optional<T> CurrentUnitOfWork.map(Function<UnitOfWork<?>, T> function) If a Unit of Work is started, execute the givenfunctionon it.voidAbstractUnitOfWork.onCleanup(Consumer<UnitOfWork<T>> handler) voidUnitOfWork.onCleanup(Consumer<UnitOfWork<T>> handler) Register givenhandlerwith the Unit of Work.voidAbstractUnitOfWork.onCommit(Consumer<UnitOfWork<T>> handler) voidUnitOfWork.onCommit(Consumer<UnitOfWork<T>> handler) Register givenhandlerwith the Unit of Work.voidAbstractUnitOfWork.onPrepareCommit(Consumer<UnitOfWork<T>> handler) voidUnitOfWork.onPrepareCommit(Consumer<UnitOfWork<T>> handler) Register givenhandlerwith the Unit of Work.voidAbstractUnitOfWork.onRollback(Consumer<UnitOfWork<T>> handler) voidUnitOfWork.onRollback(Consumer<UnitOfWork<T>> handler) Register givenhandlerwith the Unit of Work. -
Uses of UnitOfWork in org.axonframework.modelling.command
Methods in org.axonframework.modelling.command with parameters of type UnitOfWorkModifier and TypeMethodDescriptionAbstractRepository.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 UnitOfWorkModifier and TypeMethodDescriptionAnnotatedCommandHandlerInterceptor.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 UnitOfWorkModifier and TypeMethodDescriptionAnnotatedSagaRepository.unsavedSagaResource(UnitOfWork<?> unitOfWork) Returns a set of identifiers of sagas that may have changed in the context of the givenunitOfWorkand have not been saved yet. -
Uses of UnitOfWork in org.axonframework.spring.authorization
Methods in org.axonframework.spring.authorization with parameters of type UnitOfWorkModifier and TypeMethodDescriptionMessageAuthorizationHandlerInterceptor.handle(UnitOfWork<? extends T> unitOfWork, InterceptorChain interceptorChain)