Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.config | |
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.queryhandling | |
org.axonframework.spring.commandhandling.distributed.jgroups | |
org.axonframework.test.aggregate |
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 |
---|---|
List<MessageHandlerInterceptor<? super CommandMessage<?>>> |
DisruptorConfiguration.getInvokerInterceptors()
Returns the interceptors for the DisruptorCommandBus.
|
List<MessageHandlerInterceptor<? super CommandMessage<?>>> |
DisruptorConfiguration.getPublisherInterceptors()
Returns the interceptors for the DisruptorCommandBus.
|
Modifier and Type | Method and Description |
---|---|
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.
|
DisruptorConfiguration |
DisruptorConfiguration.setInvokerInterceptors(List<MessageHandlerInterceptor<? super CommandMessage<?>>> invokerInterceptors)
Configures the CommandHandlerInterceptors to use with the DisruptorCommandBus during in the invocation thread.
|
DisruptorConfiguration |
DisruptorConfiguration.setPublisherInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> publisherInterceptors)
Configures the CommandHandlerInterceptors to use with the DisruptorCommandBus during the publication of changes.
|
Modifier and Type | Method and Description |
---|---|
List<MessageHandlerInterceptor<? super EventMessage<?>>> |
EventHandlingConfiguration.interceptorsFor(Configuration configuration,
String processorName)
Returns the list of Message Handler Interceptors registered for the given
processorName . |
Modifier and Type | Method and Description |
---|---|
EventHandlingConfiguration |
EventHandlingConfiguration.registerHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
Register the given
interceptorBuilder to build an Message Handling Interceptor for Event Processors
created in this configuration. |
SagaConfiguration<S> |
SagaConfiguration.registerHandlerInterceptor(Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> handlerInterceptorBuilder)
Registers the handler interceptor provided by the given
handlerInterceptorBuilder function with
the processor defined in this configuration. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerHandlerInterceptor(String processorName,
Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
Register the given
interceptorBuilder to build an Message Handling Interceptor for the Event Processor
with given processorName . |
Modifier and Type | Method and Description |
---|---|
Registration |
EventProcessor.registerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor)
Registers the given
interceptor to this event processor. |
Registration |
AbstractEventProcessor.registerInterceptor(MessageHandlerInterceptor<? super EventMessage<?>> interceptor) |
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 messages.
|
class |
CorrelationDataInterceptor<T extends Message<?>>
Message interceptor that registers
CorrelationDataProviders with the Unit of Work. |
class |
LoggingInterceptor<T extends Message<?>>
Message Handler Interceptor that logs 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 | Method and Description |
---|---|
Registration |
SimpleQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<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 |
---|---|
void |
JGroupsConnectorFactoryBean.setInterceptors(List<MessageHandlerInterceptor<CommandMessage<?>>> interceptors)
Sets the interceptor to use in the default local segment (a SimpleCommandBus).
|
Modifier and Type | Method and Description |
---|---|
FixtureConfiguration<T> |
FixtureConfiguration.registerCommandHandlerInterceptor(MessageHandlerInterceptor<CommandMessage<?>> commandHanderInterceptor)
Register a command handler interceptor which may be invoked before or after the command has been dispatched on
the command bus to perform a task specified in the interceptor.
|
FixtureConfiguration<T> |
AggregateTestFixture.registerCommandHandlerInterceptor(MessageHandlerInterceptor<CommandMessage<?>> commandHanderInterceptor) |
Copyright © 2010–2017. All rights reserved.