Package | Description |
---|---|
org.axonframework.boot.autoconfig | |
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.commandhandling.gateway | |
org.axonframework.config | |
org.axonframework.jgroups.commandhandling | |
org.axonframework.spring.commandhandling.distributed.jgroups | |
org.axonframework.spring.commandhandling.gateway | |
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 | Method and Description |
---|---|
CommandGateway |
AxonAutoConfiguration.commandGateway(CommandBus commandBus) |
JGroupsConnectorFactoryBean |
JGroupsAutoConfiguration.jgroupsConnectorFactoryBean(Serializer messageSerializer,
CommandBus localSegment,
RoutingStrategy routingStrategy,
ConsistentHashChangeListener consistentHashChangeListener) |
SpringHttpCommandBusConnector |
SpringCloudAutoConfiguration.springHttpCommandBusConnector(CommandBus localSegment,
org.springframework.web.client.RestTemplate restTemplate,
Serializer serializer) |
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 command's name.
|
Modifier and Type | Method and Description |
---|---|
Registration |
AnnotationCommandHandlerAdapter.subscribe(CommandBus commandBus)
Subscribe this command handler to the given
commandBus . |
Registration |
AggregateAnnotationCommandHandler.subscribe(CommandBus commandBus)
Subscribe this command handler to the given
commandBus . |
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 |
---|---|
CommandBus |
AbstractCommandGateway.getCommandBus()
Returns the CommandBus used by this gateway.
|
Constructor and Description |
---|
AbstractCommandGateway(CommandBus commandBus,
RetryScheduler retryScheduler,
List<MessageDispatchInterceptor<? super CommandMessage<?>>> messageDispatchInterceptors)
Initialize the AbstractCommandGateway with given
commandBus , retryScheduler and
commandDispatchInterceptors . |
CommandGatewayFactory(CommandBus commandBus,
MessageDispatchInterceptor<CommandMessage<?>>... dispatchInterceptors)
Initialize the factory sending Commands to the given
commandBus , optionally intercepting them with
given dispatchInterceptors . |
CommandGatewayFactory(CommandBus commandBus,
RetryScheduler retryScheduler,
List<MessageDispatchInterceptor<CommandMessage<?>>> messageDispatchInterceptors)
Initialize the factory sending Commands to the given
commandBus , optionally intercepting them with
given dispatchInterceptors . |
CommandGatewayFactory(CommandBus commandBus,
RetryScheduler retryScheduler,
MessageDispatchInterceptor<CommandMessage<?>>... messageDispatchInterceptors)
Initialize the factory sending Commands to the given
commandBus , optionally intercepting them with
given dispatchInterceptors . |
DefaultCommandGateway(CommandBus commandBus,
MessageDispatchInterceptor<? super CommandMessage<?>>... messageDispatchInterceptors)
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<MessageDispatchInterceptor<? super CommandMessage<?>>> messageDispatchInterceptors)
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,
MessageDispatchInterceptor<? super CommandMessage<?>>... messageDispatchInterceptors)
Initializes a command gateway that dispatches commands to the given
commandBus after they have been
handles by the given commandDispatchInterceptors . |
RetryingCallback(CommandCallback<C,R> delegate,
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 |
---|---|
default CommandBus |
Configuration.commandBus()
Returns the Command Bus defined in this Configuration.
|
protected CommandBus |
DefaultConfigurer.defaultCommandBus(Configuration config)
Provides the default CommandBus implementation.
|
Modifier and Type | Method and Description |
---|---|
default Configurer |
Configurer.configureCommandBus(Function<Configuration,CommandBus> commandBusBuilder)
Configures the given Command Bus to use in this configuration.
|
Constructor and Description |
---|
JGroupsConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer)
Initialize the connector using the given
localSegment to handle commands on the local node, and the given
channel to connect between nodes. |
JGroupsConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer,
RoutingStrategy routingStrategy)
Initialize the connector using the given
localSegment to handle commands on the local node, and the given
channel to connect between nodes. |
JGroupsConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer,
RoutingStrategy routingStrategy,
ConsistentHashChangeListener consistentHashChangeListener)
Initialize the connector using the given
localSegment to handle commands on the local node, and the given
channel to connect between nodes. |
Modifier and Type | Method and Description |
---|---|
protected JGroupsConnector |
JGroupsConnectorFactoryBean.instantiateConnector(CommandBus localSegment,
org.jgroups.JChannel channel,
String clusterName,
Serializer serializer,
RoutingStrategy routingStrategy) |
void |
JGroupsConnectorFactoryBean.setLocalSegment(CommandBus localSegment)
Sets the CommandBus instance on which local commands must be dispatched.
|
Modifier and Type | Method and Description |
---|---|
void |
CommandGatewayFactoryBean.setCommandBus(CommandBus commandBus)
Sets the command bus on which the Gateway must dispatch commands.
|
Modifier and Type | Method and Description |
---|---|
CommandBus |
AxonConfiguration.commandBus() |
CommandBus |
AxonConfiguration.defaultCommandBus() |
Modifier and Type | Method and Description |
---|---|
CommandGateway |
AxonConfiguration.commandGateway(CommandBus commandBus)
Returns the CommandGateway used to send commands to command handlers.
|
void |
CommandHandlerSubscriber.setCommandBus(CommandBus commandBus)
Sets the command bus to use when subscribing command handlers.
|
Constructor and Description |
---|
SpringHttpCommandBusConnector(CommandBus localCommandBus,
org.springframework.web.client.RestOperations restOperations,
Serializer serializer) |
Modifier and Type | Method and Description |
---|---|
CommandBus |
FixtureConfiguration.getCommandBus()
Returns the command bus used by this fixture.
|
CommandBus |
AggregateTestFixture.getCommandBus() |
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–2018. All rights reserved.