| Package | Description | 
|---|---|
| org.axonframework.disruptor.commandhandling | |
| org.axonframework.eventhandling | Classes related to event handling and dispatching, such as  Event Listenersand theEvent 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 | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | CommandHandlingEntryDataHolder 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 thechain, to thehandler. | 
| Modifier and Type | Method and Description | 
|---|---|
| Object | LoggingInterceptor. handle(UnitOfWork<? extends T> unitOfWork,
      InterceptorChain interceptorChain) | 
| Object | CorrelationDataInterceptor. handle(UnitOfWork<? extends T> unitOfWork,
      InterceptorChain interceptorChain) | 
| Object | TransactionManagingInterceptor. handle(UnitOfWork<? extends T> unitOfWork,
      InterceptorChain interceptorChain) | 
| Object | BeanValidationInterceptor. handle(UnitOfWork<? extends T> unitOfWork,
      InterceptorChain interceptorChain) | 
| 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<?>> | AbstractUnitOfWork. parent() | 
| Optional<UnitOfWork<?>> | UnitOfWork. parent()Returns an optional for the parent of this Unit of Work. | 
| 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  unitOfWorkto the current thread. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected abstract void | AbstractUnitOfWork. addHandler(UnitOfWork.Phase phase,
          Consumer<UnitOfWork<T>> handler)Register the given  handlerwith the Unit of Work. | 
| protected void | DefaultUnitOfWork. addHandler(UnitOfWork.Phase phase,
          Consumer<UnitOfWork<T>> handler) | 
| void | MessageProcessingContext. addHandler(UnitOfWork.Phase phase,
          Consumer<UnitOfWork<T>> handler)Adds a handler to the collection. | 
| protected void | BatchingUnitOfWork. addHandler(UnitOfWork.Phase phase,
          Consumer<UnitOfWork<T>> handler) | 
| void | AbstractUnitOfWork. afterCommit(Consumer<UnitOfWork<T>> handler) | 
| void | UnitOfWork. afterCommit(Consumer<UnitOfWork<T>> handler)Register given  handlerwith the Unit of Work. | 
| static boolean | CurrentUnitOfWork. ifStarted(Consumer<UnitOfWork<?>> consumer)If a UnitOfWork is started, invokes the given  consumerwith 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  functionon it. | 
| void | AbstractUnitOfWork. onCleanup(Consumer<UnitOfWork<T>> handler) | 
| void | UnitOfWork. onCleanup(Consumer<UnitOfWork<T>> handler)Register given  handlerwith the Unit of Work. | 
| void | AbstractUnitOfWork. onCommit(Consumer<UnitOfWork<T>> handler) | 
| void | UnitOfWork. onCommit(Consumer<UnitOfWork<T>> handler)Register given  handlerwith the Unit of Work. | 
| void | AbstractUnitOfWork. onPrepareCommit(Consumer<UnitOfWork<T>> handler) | 
| void | UnitOfWork. onPrepareCommit(Consumer<UnitOfWork<T>> handler)Register given  handlerwith the Unit of Work. | 
| void | AbstractUnitOfWork. onRollback(Consumer<UnitOfWork<T>> handler) | 
| void | UnitOfWork. onRollback(Consumer<UnitOfWork<T>> handler)Register given  handlerwith the Unit of Work. | 
| 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  unitOfWorkand
 have not been saved yet. | 
Copyright © 2010–2020. All rights reserved.