Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.commandhandling.distributed | |
org.axonframework.eventhandling |
Classes related to event handling and dispatching, such as
Event Listeners and the Event Bus . |
org.axonframework.eventhandling.saga | |
org.axonframework.jgroups.commandhandling | |
org.axonframework.messaging |
Classes related to message processing in Axon Framework.
|
org.axonframework.spring.config | |
org.axonframework.springcloud.commandhandling | |
org.axonframework.test.aggregate | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateAnnotationCommandHandler<T>
Command handler that handles commands based on
CommandHandler
annotations on an aggregate. |
class |
AnnotationCommandHandlerAdapter
Adapter that turns any
@CommandHandler annotated bean into a MessageHandler implementation. |
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with given commandName . |
Registration |
CommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with the given commandName . |
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.
|
Registration |
DisruptorCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Modifier and Type | Method and Description |
---|---|
Registration |
DistributedCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribe the given
handler to commands with the given commandName . |
Registration |
CommandBusConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler)
Subscribes a command message handler for commands with given
commandName . |
Modifier and Type | Interface and Description |
---|---|
interface |
EventHandlerInvoker
Interface for an event message handler that defers handling to one or more other handlers.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleEventHandlerInvoker
Implementation of an
EventHandlerInvoker that forwards events to a list of registered EventListeners . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSagaManager<T>
Abstract implementation of the SagaManager interface that provides basic functionality required by most SagaManager
implementations.
|
class |
AnnotatedSagaManager<T>
Implementation of the SagaManager that uses annotations on the Sagas to describe the lifecycle management.
|
Modifier and Type | Method and Description |
---|---|
Registration |
JGroupsConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
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 | Method and Description |
---|---|
void |
CommandHandlerSubscriber.setCommandHandlers(Collection<MessageHandler> commandHandlers)
Sets the command handlers to subscribe to the bus.
|
Modifier and Type | Method and Description |
---|---|
Registration |
SpringHttpCommandBusConnector.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Modifier and Type | Method and Description |
---|---|
FixtureConfiguration<T> |
FixtureConfiguration.registerCommandHandler(Class<?> payloadType,
MessageHandler<CommandMessage<?>> commandHandler)
Registers a
commandHandler to handle commands of the given commandType with the
command bus used by this fixture. |
FixtureConfiguration<T> |
AggregateTestFixture.registerCommandHandler(Class<?> payloadType,
MessageHandler<CommandMessage<?>> commandHandler) |
FixtureConfiguration<T> |
FixtureConfiguration.registerCommandHandler(String commandName,
MessageHandler<CommandMessage<?>> commandHandler)
Registers a
commandHandler to handle commands of the given commandType with the
command bus used by this fixture. |
FixtureConfiguration<T> |
AggregateTestFixture.registerCommandHandler(String commandName,
MessageHandler<CommandMessage<?>> commandHandler) |
Modifier and Type | Method and Description |
---|---|
Map<String,MessageHandler<? super CommandMessage<?>>> |
RecordingCommandBus.getSubscriptions()
Returns a Map will all Command Names and their Command Handler that have been subscribed to this command bus.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RecordingCommandBus.isSubscribed(MessageHandler<? super CommandMessage<?>> commandHandler)
Indicates whether the given
commandHandler is subscribed to this command bus. |
<C> boolean |
RecordingCommandBus.isSubscribed(String commandName,
MessageHandler<? super CommandMessage<?>> commandHandler)
Indicates whether the given
commandHandler is subscribed to commands of the given
commandType on this command bus. |
Registration |
RecordingCommandBus.subscribe(String commandName,
MessageHandler<? super CommandMessage<?>> handler) |
Copyright © 2010–2017. All rights reserved.