Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration |
AxonServerConfiguration.Builder.build() |
Constructor and Description |
---|
AxonServerConnectionManager(AxonServerConfiguration connectInformation) |
Constructor and Description |
---|
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy) |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator) |
CommandSerializer(Serializer serializer,
AxonServerConfiguration configuration) |
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.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> eventProcessingConfiguration,
Function<Configuration,AxonServerConnectionManager> connectionManager,
Function<Configuration,AxonServerConfiguration> axonServerConfiguration) |
Constructor and Description |
---|
AxonServerQueryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
QueryUpdateEmitter updateEmitter,
QueryBus localSegment,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator)
Creates an instance of the AxonServerQueryBus
|
QuerySerializer(Serializer messageSerializer,
Serializer genericSerializer,
AxonServerConfiguration configuration) |
Constructor and Description |
---|
AxonServerSubscriptionQueryResult(SubscriptionQuery query,
Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn,
AxonServerConfiguration configuration,
SubscriptionQueryBackpressure backPressure,
int bufferSize,
Runnable onDispose) |
SubscriptionMessageSerializer(AxonServerConfiguration conf,
Serializer messageSerializer,
Serializer genericSerializer) |
Constructor and Description |
---|
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver,
AxonServerConfiguration configuration,
Function<FlowControl,T> requestWrapper,
Predicate<T> isConfirmationMessage) |
Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration |
AxonServerAutoConfiguration.axonServerConfiguration() |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus |
AxonServerAutoConfiguration.commandBus(TransactionManager txManager,
AxonConfiguration axonConfiguration,
AxonServerConfiguration axonServerConfiguration,
Serializer serializer,
AxonServerConnectionManager axonServerConnectionManager,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator) |
EventStore |
AxonServerAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
AxonConfiguration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
AxonServerConnectionManager |
AxonServerAutoConfiguration.platformConnectionManager(AxonServerConfiguration routingConfiguration) |
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–2018. All rights reserved.