Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration |
AxonServerConfiguration.Builder.build()
Initializes a
AxonServerConfiguration as specified through this Builder. |
Modifier and Type | Method and Description |
---|---|
AxonServerConnectionManager.Builder |
AxonServerConnectionManager.Builder.axonServerConfiguration(AxonServerConfiguration axonServerConfiguration)
Sets the
AxonServerConfiguration used to correctly configure connections between Axon clients and
Axon Server. |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration used to configure several components within the Axon Server Command
Bus, like setting the client id or the number of command handling threads used. |
Constructor and Description |
---|
CommandSerializer(Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
CommandMessage s and CommandResultMessage s into Axon
Server gRPC messages and vice versa. |
Modifier and Type | Method and Description |
---|---|
AxonServerEventStoreFactory.Builder |
AxonServerEventStoreFactory.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration describing the servers to connect with and how to manage flow
control. |
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration describing the servers to connect with and how to manage flow
control. |
Constructor and Description |
---|
EventProcessorInfoConfiguration(Function<Configuration,EventProcessingConfiguration> eventProcessingConfigurationBuilder,
Function<Configuration,AxonServerConnectionManager> connectionManagerBuilder,
Function<Configuration,AxonServerConfiguration> axonServerConfigurationBuilder)
Creates an EventProcessorInfoConfiguration using the provided functions to retrieve the
EventProcessingConfiguration , AxonServerConnectionManager and AxonServerConfiguration . |
Constructor and Description |
---|
HeartbeatConfiguration(Function<Configuration,AxonServerConnectionManager> connectionManagerSupplier,
Function<Configuration,AxonServerConfiguration> axonServerConfigurationSupplier)
Deprecated.
Creates a
HeartbeatConfiguration using the provided functions to retrieve the AxonServerConnectionManager and AxonServerConfiguration . |
Constructor and Description |
---|
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConfiguration axonServerConfiguration)
Initialize a
EventProcessorControlService . |
Modifier and Type | Method and Description |
---|---|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration used to configure several components within the Axon Server Query
Bus, like setting the client id or the number of query handling threads used. |
Constructor and Description |
---|
QuerySerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
QueryMessage s and QueryResponseMessage s into Axon
Server gRPC messages and vice versa. |
Constructor and Description |
---|
SubscriptionMessageSerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
SubscriptionQueryMessage s, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage s into Axon Server gRPC messages
and vice versa. |
Constructor and Description |
---|
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver,
AxonServerConfiguration configuration,
Function<io.axoniq.axonserver.grpc.FlowControl,T> requestWrapper,
Predicate<T> isConfirmationMessage)
Deprecated.
Constructs a
FlowControllingStreamObserver . |
Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration |
AxonServerAutoConfiguration.axonServerConfiguration() |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus |
AxonServerBusAutoConfiguration.axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
CommandBus localSegment,
Serializer messageSerializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandLoadFactorProvider loadFactorProvider,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver,
CommandBusSpanFactory spanFactory) |
AxonServerEventStoreFactory |
AxonServerBusAutoConfiguration.axonServerEventStoreFactory(AxonServerConfiguration axonServerConfig,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer,
Configuration config) |
CommandLoadFactorProvider |
AxonServerAutoConfiguration.commandLoadFactorProvider(AxonServerConfiguration configuration) |
EventStore |
AxonServerBusAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
Configuration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
ConfigurerModule |
AxonServerAutoConfiguration.persistentStreamProcessorsConfigurerModule(EventProcessorProperties processorProperties,
AxonServerConfiguration axonServerConfiguration)
Creates a
ConfigurerModule to configure
sequencing policies for persistent streams
connected to subscribing event processors with
a dead letter queue. |
AxonServerConnectionManager |
AxonServerAutoConfiguration.DefaultConnectionManagerConfiguration.platformConnectionManager(AxonServerConfiguration axonServerConfig,
TagsConfigurationProperties tagProperties,
ManagedChannelCustomizer managedChannelCustomizer) |
AxonServerConnectionManager |
AxonServerAutoConfiguration.ConnectionDetailsConnectionManagerConfiguration.platformConnectionManager(AxonServerConnectionDetails connectionDetails,
AxonServerConfiguration axonServerConfig,
TagsConfigurationProperties tagProperties,
ManagedChannelCustomizer managedChannelCustomizer) |
EventProcessorInfoConfiguration |
AxonServerAutoConfiguration.processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConnectionManager connectionManager,
AxonServerConfiguration configuration) |
AxonServerQueryBus |
AxonServerBusAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
Configuration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) |
Constructor and Description |
---|
PropertiesAxonServerConnectionDetails(AxonServerConfiguration configuration)
Constructs a
PropertiesAxonServerConnectionDetails instance based on the given configuration . |
Copyright © 2010–2024. All rights reserved.