Package | Description |
---|---|
org.axonframework.axonserver.connector.command | |
org.axonframework.axonserver.connector.query | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.distributed | |
org.axonframework.config | |
org.axonframework.deadline | |
org.axonframework.disruptor.commandhandling | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.deadletter | |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.messaging.interceptors | |
org.axonframework.modelling.command.inspection | |
org.axonframework.queryhandling | |
org.axonframework.test.aggregate | |
org.axonframework.test.deadline | |
org.axonframework.test.saga | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Method and Description |
---|---|
Registration |
AxonServerCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
AxonServerQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?,?>> interceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor)
Registers the given interceptor to the command bus.
|
Modifier and Type | Method and Description |
---|---|
Registration |
DistributedCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Modifier and Type | Field and Description |
---|---|
protected List<BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>>> |
EventProcessingModule.defaultHandlerInterceptors |
protected Map<String,List<Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>>>> |
EventProcessingModule.handlerInterceptorsBuilders |
Modifier and Type | Method and Description |
---|---|
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
EventProcessingModule.interceptorsFor(String processorName) |
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
EventProcessingConfiguration.interceptorsFor(String processorName)
|
Modifier and Type | Method and Description |
---|---|
protected List<MessageHandlerInterceptor<? super DeadlineMessage<?>>> |
AbstractDeadlineManager.handlerInterceptors()
Provides a list of registered handler interceptors.
|
Modifier and Type | Method and Description |
---|---|
Registration |
AbstractDeadlineManager.registerHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> handlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
DisruptorCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.invokerInterceptors(List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors)
Set the
MessageHandlerInterceptor of generic type CommandMessage to use with the DisruptorCommandBus during in the invocation thread. |
DisruptorCommandBus.Builder |
DisruptorCommandBus.Builder.publisherInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> publisherInterceptors)
Configures the
MessageHandlerInterceptor of generic type CommandMessage to use with the
DisruptorCommandBus during the publication of changes. |
void |
CommandHandlingEntry.reset(CommandMessage<?> newCommand,
MessageHandler<? super CommandMessage<?>> newCommandHandler,
int newInvokerSegmentId,
int newPublisherSegmentId,
BlacklistDetectingCallback<?,?> newCallback,
List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors,
List<MessageHandlerInterceptor<? super CommandMessage<?>>> publisherInterceptors)
Resets this entry, preparing it for use for another command.
|
void |
CommandHandlingEntry.reset(CommandMessage<?> newCommand,
MessageHandler<? super CommandMessage<?>> newCommandHandler,
int newInvokerSegmentId,
int newPublisherSegmentId,
BlacklistDetectingCallback<?,?> newCallback,
List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors,
List<MessageHandlerInterceptor<? super CommandMessage<?>>> publisherInterceptors)
Resets this entry, preparing it for use for another command.
|
Modifier and Type | Method and Description |
---|---|
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
EventProcessor.getHandlerInterceptors()
Return the list of already registered
MessageHandlerInterceptor s for this event processor. |
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
AbstractEventProcessor.getHandlerInterceptors() |
Modifier and Type | Method and Description |
---|---|
Registration |
AbstractEventProcessor.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
DeadLetteringEventHandlerInvoker.registerHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
MessageHandlerInterceptorSupport.registerHandlerInterceptor(MessageHandlerInterceptor<? super T> handlerInterceptor)
Register the given
handlerInterceptor . |
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 | Class and Description |
---|---|
class |
BeanValidationInterceptor<T extends Message<?>>
Interceptor that applies JSR303 bean validation on incoming
Message s. |
class |
CorrelationDataInterceptor<T extends Message<?>>
Message interceptor that registers
CorrelationDataProviders with the Unit of Work. |
class |
LoggingInterceptor<T extends Message<?>>
MessageDispatchInterceptor and MessageHandlerInterceptor implementation that logs dispatched and
incoming messages, and their result, to a SLF4J logger. |
class |
TransactionManagingInterceptor<T extends Message<?>>
Interceptor that uses a
TransactionManager to start a new transaction before a Message is handled. |
Modifier and Type | Class and Description |
---|---|
class |
AnnotatedCommandHandlerInterceptor<T>
Annotated command handler interceptor on aggregate.
|
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?,?>> interceptor)
Registers an interceptor that is used to intercept Queries before they are passed to their respective handlers.
|
Modifier and Type | Method and Description |
---|---|
FixtureConfiguration<T> |
FixtureConfiguration.registerCommandHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> commandHandlerInterceptor)
Register a
MessageHandlerInterceptor for CommandMessage s which will be invoked before or after
the command has been dispatched on the CommandBus to perform a task specified in the interceptor. |
FixtureConfiguration<T> |
AggregateTestFixture.registerCommandHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> commandHandlerInterceptor) |
FixtureConfiguration<T> |
FixtureConfiguration.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor)
Registers a deadline handler interceptor which will always be invoked before a deadline is handled to perform a
task specified in the interceptor.
|
FixtureConfiguration<T> |
AggregateTestFixture.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
Registration |
StubDeadlineManager.registerHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> handlerInterceptor) |
Modifier and Type | Method and Description |
---|---|
FixtureConfiguration |
SagaTestFixture.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor) |
FixtureConfiguration |
FixtureConfiguration.registerDeadlineHandlerInterceptor(MessageHandlerInterceptor<? super DeadlineMessage<?>> deadlineHandlerInterceptor)
Registers a deadline handler interceptor which will always be invoked before a deadline is handled to perform a
task specified in the interceptor.
|
FixtureConfiguration |
SagaTestFixture.registerEventHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> eventHandlerInterceptor) |
default FixtureConfiguration |
FixtureConfiguration.registerEventHandlerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> eventHandlerInterceptor)
Registers a
MessageHandlerInterceptor for EventMessages . |
Modifier and Type | Method and Description |
---|---|
Registration |
RecordingCommandBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>> handlerInterceptor) |
Copyright © 2010–2024. All rights reserved.