Package | Description |
---|---|
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.annotation |
Classes that provide annotation support for command handling.
|
org.axonframework.commandhandling.disruptor | |
org.axonframework.commandhandling.distributed | |
org.axonframework.commandhandling.distributed.jgroups | |
org.axonframework.commandhandling.gateway | |
org.axonframework.test |
Classes in support of testing Axon based applications.
|
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Class and Description |
---|---|
class |
AsynchronousCommandBus
Specialization of the SimpleCommandBus that processed Commands asynchronously from the calling thread.
|
class |
SimpleCommandBus
Implementation of the CommandBus that dispatches commands to the handlers subscribed to that specific type of
command.
|
Modifier and Type | Method and Description |
---|---|
void |
AnnotationCommandHandlerBeanPostProcessor.setCommandBus(CommandBus commandBus)
Sets the event bus to which detected event listeners should be subscribed.
|
void |
AggregateAnnotationCommandHandlerFactoryBean.setCommandBus(CommandBus commandBus)
Sets the CommandBus to subscribe the handler to
|
static void |
AggregateAnnotationCommandHandler.subscribe(AggregateAnnotationCommandHandler<?> aggregateAnnotationCommandHandler,
CommandBus commandBus)
Subscribe the given
aggregateAnnotationCommandHandler to the given commandBus . |
static void |
AnnotationCommandHandlerAdapter.subscribe(AnnotationCommandHandlerAdapter annotationCommandHandler,
CommandBus commandBus)
Subscribe the given
annotationCommandHandler to the given commandBus . |
static <T extends AggregateRoot> |
AggregateAnnotationCommandHandler.subscribe(Class<T> aggregateType,
Repository<T> repository,
CommandBus commandBus)
Subscribe a handler for the given aggregate type to the given command bus.
|
static <T extends AggregateRoot> |
AggregateAnnotationCommandHandler.subscribe(Class<T> aggregateType,
Repository<T> repository,
CommandBus commandBus,
CommandTargetResolver commandTargetResolver)
Subscribe a handler for the given aggregate type to the given command bus.
|
static AnnotationCommandHandlerAdapter |
AnnotationCommandHandlerAdapter.subscribe(Object annotatedCommandHandler,
CommandBus commandBus)
Subscribe the annotated command handler to the given command bus.
|
Modifier and Type | Class and Description |
---|---|
class |
DisruptorCommandBus
Asynchronous CommandBus implementation with very high performance characteristics.
|
Modifier and Type | Class and Description |
---|---|
class |
DistributedCommandBus
Implementation of a
CommandBus that is aware of multiple instances of a CommandBus working together to
spread load. |
Modifier and Type | Method and Description |
---|---|
void |
JGroupsConnectorFactoryBean.setLocalSegment(CommandBus localSegment)
Sets the CommandBus instance on which local commands must be dispatched.
|
Constructor and Description |
---|
JGroupsConnector(org.jgroups.JChannel channel,
String clusterName,
CommandBus localSegment,
Serializer serializer)
Initializes the Connector using given resources.
|
Modifier and Type | Method and Description |
---|---|
void |
CommandGatewayFactoryBean.setCommandBus(CommandBus commandBus)
Sets the command bus on which the Gateway must dispatch commands.
|
Constructor and Description |
---|
AbstractCommandGateway(CommandBus commandBus,
RetryScheduler retryScheduler,
List<CommandDispatchInterceptor> commandDispatchInterceptors)
Initialize the AbstractCommandGateway with given
commandBus , retryScheduler and
commandDispatchInterceptors . |
DefaultCommandGateway(CommandBus commandBus,
CommandDispatchInterceptor... commandDispatchInterceptors)
Initializes a command gateway that dispatches commands to the given
commandBus after they have been
handles by the given commandDispatchInterceptors . |
DefaultCommandGateway(CommandBus commandBus,
RetryScheduler retryScheduler,
CommandDispatchInterceptor... commandDispatchInterceptors)
Initializes a command gateway that dispatches commands to the given
commandBus after they have been
handles by the given commandDispatchInterceptors . |
DefaultCommandGateway(CommandBus commandBus,
RetryScheduler retryScheduler,
List<CommandDispatchInterceptor> commandDispatchInterceptors)
Initializes a command gateway that dispatches commands to the given
commandBus after they have been
handles by the given commandDispatchInterceptors . |
GatewayProxyFactory(CommandBus commandBus,
CommandDispatchInterceptor... dispatchInterceptors)
Initialize the factory sending Commands to the given
commandBus , optionally intercepting them with
given dispatchInterceptors . |
GatewayProxyFactory(CommandBus commandBus,
RetryScheduler retryScheduler,
CommandDispatchInterceptor... commandDispatchInterceptors)
Initialize the factory sending Commands to the given
commandBus , optionally intercepting them with
given dispatchInterceptors . |
GatewayProxyFactory(CommandBus commandBus,
RetryScheduler retryScheduler,
List<CommandDispatchInterceptor> commandDispatchInterceptors)
Initialize the factory sending Commands to the given
commandBus , optionally intercepting them with
given dispatchInterceptors . |
RetryingCallback(CommandCallback<R> delegate,
CommandMessage commandMessage,
RetryScheduler retryScheduler,
CommandBus commandBus)
Initialize the RetryingCallback with the given
delegate , representing the actual callback passed as
a parameter to dispatch, the given commandMessage , retryScheduler and
commandBus . |
Modifier and Type | Method and Description |
---|---|
CommandBus |
GivenWhenThenTestFixture.getCommandBus() |
CommandBus |
FixtureConfiguration.getCommandBus()
Returns the command bus used by this fixture.
|
Modifier and Type | Class and Description |
---|---|
class |
RecordingCommandBus
CommandBus implementation that does not perform any actions on subscriptions or dispatched commands, but records
them instead.
|
Copyright © 2010-2014. All Rights Reserved.