Constructor and Description |
---|
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy)
Instantiate an Axon Server
CommandBus client. |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator)
Instantiate an Axon Server Command Bus client.
|
Constructor and Description |
---|
AxonServerEventStoreClient(AxonServerConfiguration eventStoreConfiguration,
AxonServerConnectionManager axonServerConnectionManager)
Initialize the Event Store Client using given
eventStoreConfiguration and given platformConnectionManager . |
Modifier and Type | Method and Description |
---|---|
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.platformConnectionManager(AxonServerConnectionManager axonServerConnectionManager)
Sets the
AxonServerConnectionManager managing the connections to the AxonServer platform. |
Constructor and Description |
---|
EventProcessorInfoConfiguration(Function<Configuration,EventProcessingConfiguration> eventProcessingConfiguration,
Function<Configuration,AxonServerConnectionManager> connectionManager,
Function<Configuration,AxonServerConfiguration> axonServerConfiguration) |
Constructor and Description |
---|
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
EventProcessorController eventProcessorController)
Initialize a
EventProcessorControlService which adds Consumer s to the given
AxonServerConnectionManager on PlatformOutboundInstruction s. |
Constructor and Description |
---|
GrpcEventProcessorInfoSource(EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConnectionManager axonServerConnectionManager)
Instantiate a
EventProcessorInfoSource which can send EventProcessor status info to Axon Server. |
Constructor and Description |
---|
AxonServerQueryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
QueryUpdateEmitter updateEmitter,
QueryBus localSegment,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator)
Creates an instance of the Axon Server
QueryBus client. |
Modifier and Type | Method and Description |
---|---|
AxonServerConnectionManager |
AxonServerAutoConfiguration.platformConnectionManager(AxonServerConfiguration routingConfiguration) |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus |
AxonServerAutoConfiguration.axonServerCommandBus(AxonServerConfiguration axonServerConfiguration,
Serializer serializer,
AxonServerConnectionManager axonServerConnectionManager,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandBus localSegment) |
EventStore |
AxonServerAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
AxonConfiguration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
EventProcessorInfoConfiguration |
AxonServerAutoConfiguration.processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConnectionManager connectionManager,
AxonServerConfiguration configuration) |
AxonServerQueryBus |
AxonServerAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
AxonConfiguration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler) |
Copyright © 2010–2019. All rights reserved.