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. |
Constructor and Description |
---|
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy)
Deprecated.
in favor of using the
AxonServerCommandBus.Builder (with the convenience AxonServerCommandBus.builder() method) to instantiate
an Axon Server Command Bus |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator)
Deprecated.
in favor of using the
AxonServerCommandBus.Builder (with the convenience AxonServerCommandBus.builder() method) to instantiate
an Axon Server Command Bus |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver)
Deprecated.
in favor of using the
AxonServerCommandBus.Builder (with the convenience AxonServerCommandBus.builder() method) to instantiate
an Axon Server Command Bus |
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.