Package | Description |
---|---|
org.axonframework.axonserver.connector.command | |
org.axonframework.commandhandling |
Classes that implement the concept of command handling using explicit command objects.
|
org.axonframework.commandhandling.distributed | |
org.axonframework.commandhandling.gateway | |
org.axonframework.config | |
org.axonframework.disruptor.commandhandling | |
org.axonframework.modelling.command | |
org.axonframework.spring.config | |
org.axonframework.springboot.autoconfig | |
org.axonframework.test.aggregate | |
org.axonframework.test.saga | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Class and Description |
---|---|
class |
AxonServerCommandBus
Axon
CommandBus implementation that connects to Axon Server to submit and receive commands and command
responses. |
Modifier and Type | Method and Description |
---|---|
CommandBus |
AxonServerCommandBus.localSegment() |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.localSegment(CommandBus localSegment)
Sets the local
CommandBus used to dispatch incoming commands to the local environment. |
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 . |
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 |
DistributedCommandBus.localSegment()
Return the message bus of type
MessageBus which is regarded as the local segment for this implementation. |
Modifier and Type | Method and Description |
---|---|
default Optional<CommandBus> |
CommandBusConnector.localSegment()
Return an
Optional containing the CommandBus which is used by this CommandBusConnector to
dispatch local and incoming CommandMessage s on. |
Modifier and Type | Method and Description |
---|---|
CommandBus |
AbstractCommandGateway.getCommandBus()
Returns the CommandBus used by this gateway.
|
Modifier and Type | Method and Description |
---|---|
DefaultCommandGateway.Builder |
DefaultCommandGateway.Builder.commandBus(CommandBus commandBus) |
CommandGatewayFactory.Builder |
CommandGatewayFactory.Builder.commandBus(CommandBus commandBus)
Sets the
CommandBus on which to dispatch CommandMessage s. |
AbstractCommandGateway.Builder |
AbstractCommandGateway.Builder.commandBus(CommandBus commandBus)
Sets the
CommandBus used to dispatch commands. |
Constructor and Description |
---|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
DisruptorCommandBus
Asynchronous CommandBus implementation with very high performance characteristics.
|
Modifier and Type | Method and Description |
---|---|
Registration |
AggregateAnnotationCommandHandler.subscribe(CommandBus commandBus)
Subscribe this command handler to the given
commandBus . |
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.
|
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus |
AxonServerAutoConfiguration.axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
CommandBus localSegment,
Serializer messageSerializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandLoadFactorProvider loadFactorProvider,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver) |
CommandGateway |
AxonAutoConfiguration.commandGateway(CommandBus commandBus) |
Modifier and Type | Method and Description |
---|---|
CommandBus |
FixtureConfiguration.getCommandBus()
Returns the command bus used by this fixture.
|
CommandBus |
AggregateTestFixture.getCommandBus() |
Modifier and Type | Method and Description |
---|---|
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–2020. All rights reserved.