Index (Axon Framework - Axon Server Connector 4.13.2 API)

A B C D E F G H I L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(TopologyChange) - Method in interface org.axonframework.axonserver.connector.TopologyChangeListener
ActiveGrpcChannelChecker - Class in org.axonframework.axonserver.connector.heartbeat.connection.checker: Deprecated.
in through use of the AxonServer java connector
ActiveGrpcChannelChecker(AxonServerConnectionManager, String) - Constructor for class org.axonframework.axonserver.connector.heartbeat.connection.checker.ActiveGrpcChannelChecker: Deprecated.

Constructs an ActiveGrpcChannelChecker based on the connection manager.
andMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
andMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
andMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
andMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
andThen(AxonServerEventStoreFactory.AxonServerEventStoreConfiguration) - Method in interface org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.AxonServerEventStoreConfiguration: Returns a configuration that applies the given other configuration after applying this.
apply(O) - Method in class org.axonframework.axonserver.connector.util.GrpcObjectSerializer
apply(Configuration) - Method in class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider
apply(Message) - Method in class org.axonframework.axonserver.connector.util.GrpcPayloadSerializer
apply(MetaData) - Method in class org.axonframework.axonserver.connector.util.GrpcMetadataSerializer
AUTHENTICATION_INVALID_TOKEN - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
AUTHENTICATION_TOKEN_MISSING - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
awaitTermination(long, TimeUnit) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
axonFrameworkVersionResolver(Supplier<String>) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Deprecated.
Not ued anymore
AxonProcessorInstructionHandler(EventProcessor, String) - Constructor for class org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler
AxonServerCommandBus - Class in org.axonframework.axonserver.connector.command: Axon CommandBus implementation that connects to Axon Server to submit and receive commands and command responses.
AxonServerCommandBus(AxonServerCommandBus.Builder) - Constructor for class org.axonframework.axonserver.connector.command.AxonServerCommandBus: Instantiate a AxonServerCommandBus based on the fields contained in the AxonServerCommandBus.Builder.
AxonServerCommandBus.Builder - Class in org.axonframework.axonserver.connector.command: Builder class to instantiate an AxonServerCommandBus.
AxonServerCommandDispatchException - Exception in org.axonframework.axonserver.connector.command: Exception thrown if there is a problem dispatching a command on Axon Server.
AxonServerCommandDispatchException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.command.AxonServerCommandDispatchException: Initialize the exception with given errorCode and errorMessage.
AxonServerCommandDispatchException(String, String, Throwable) - Constructor for exception org.axonframework.axonserver.connector.command.AxonServerCommandDispatchException
axonServerConfiguration(AxonServerConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Sets the AxonServerConfiguration used to correctly configure connections between Axon clients and Axon Server.
AxonServerConfiguration - Class in org.axonframework.axonserver.connector: Configuration class provided configurable fields and defaults for anything Axon Server related.
AxonServerConfiguration() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration: Instantiate a default AxonServerConfiguration.
AxonServerConfiguration.Builder - Class in org.axonframework.axonserver.connector
AxonServerConfiguration.Eventhandling - Class in org.axonframework.axonserver.connector
AxonServerConfiguration.Eventhandling.ProcessorSettings - Class in org.axonframework.axonserver.connector
AxonServerConfiguration.EventStoreConfiguration - Class in org.axonframework.axonserver.connector
AxonServerConfiguration.FlowControlConfiguration - Class in org.axonframework.axonserver.connector: Configuration class for Flow Control of specific message types.
AxonServerConfiguration.HeartbeatConfiguration - Class in org.axonframework.axonserver.connector
AxonServerConfiguration.PersistentStreamSettings - Class in org.axonframework.axonserver.connector
axonServerConnectionManager - Variable in class org.axonframework.axonserver.connector.processor.EventProcessorControlService
axonServerConnectionManager(AxonServerConnectionManager) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the AxonServerConnectionManager used to create connections between this application and an Axon Server instance.
axonServerConnectionManager(AxonServerConnectionManager) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the AxonServerConnectionManager used to create connections between this application and an Axon Server instance.
AxonServerConnectionManager - Class in org.axonframework.axonserver.connector: The component which manages all the connections which an Axon client can establish with an Axon Server instance.
AxonServerConnectionManager(AxonServerConnectionManager.Builder, AxonServerConnectionFactory) - Constructor for class org.axonframework.axonserver.connector.AxonServerConnectionManager: Instantiate a AxonServerConnectionManager based on the fields contained in the AxonServerConnectionManager.Builder, using the given connectionFactory to obtain connections to AxonServer.
AxonServerConnectionManager.Builder - Class in org.axonframework.axonserver.connector: Builder class to instantiate an AxonServerConnectionManager.
AxonServerEventScheduler - Class in org.axonframework.axonserver.connector.event.axon: Implementation of the EventScheduler that uses Axon Server to schedule the events.
AxonServerEventScheduler(AxonServerEventScheduler.Builder) - Constructor for class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Instantiates an AxonServerEventScheduler using the given AxonServerEventScheduler.Builder.
AxonServerEventScheduler.Builder - Class in org.axonframework.axonserver.connector.event.axon: Builder class to instantiate an AxonServerEventScheduler.
AxonServerEventStore - Class in org.axonframework.axonserver.connector.event.axon: Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.
AxonServerEventStore(AxonServerEventStore.Builder) - Constructor for class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore: Instantiate a AxonServerEventStore based on the fields contained in the AxonServerEventStore.Builder.
AxonServerEventStore.Builder - Class in org.axonframework.axonserver.connector.event.axon: Builder class to instantiate a AxonServerEventStore.
AxonServerEventStoreFactory - Class in org.axonframework.axonserver.connector.event.axon: A factory towards AxonServerEventStores.
AxonServerEventStoreFactory(AxonServerEventStoreFactory.Builder) - Constructor for class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory: Instantiate a AxonServerEventStoreFactory based on the fields contained in the AxonServerEventStoreFactory.Builder.
AxonServerEventStoreFactory.AxonServerEventStoreConfiguration - Interface in org.axonframework.axonserver.connector.event.axon: Contract defining AxonServerEventStore.Builder based configuration when constructing an AxonServerEventStore.
AxonServerEventStoreFactory.Builder - Class in org.axonframework.axonserver.connector.event.axon: Builder class to instantiate an AxonServerEventStoreFactory.
AxonServerException - Exception in org.axonframework.axonserver.connector: Generic exception indicating an error related to AxonServer.
AxonServerException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.AxonServerException: Initializes the exception using the given code and errorMessage.
AxonServerException(String, String) - Constructor for exception org.axonframework.axonserver.connector.AxonServerException: Initializes the exception using the given code and message.
AxonServerException(String, String, String, List<String>) - Constructor for exception org.axonframework.axonserver.connector.AxonServerException: Initializes the exception using the given message, code, source and details.
AxonServerException(String, String, Throwable) - Constructor for exception org.axonframework.axonserver.connector.AxonServerException: Initializes the exception using the given message, code, and cause.
AxonServerNonTransientRemoteCommandHandlingException - Exception in org.axonframework.axonserver.connector.command: Exception indicating a non-transient problem that was reported by the remote end of a connection.
AxonServerNonTransientRemoteCommandHandlingException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.command.AxonServerNonTransientRemoteCommandHandlingException: Initialize the exception with given errorCode and errorMessage.
AxonServerNonTransientRemoteQueryHandlingException - Exception in org.axonframework.axonserver.connector.query: Exception indicating a non-transient problem that was reported during query handling by the remote end of a connection.
AxonServerNonTransientRemoteQueryHandlingException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.query.AxonServerNonTransientRemoteQueryHandlingException: Initialize the exception with given errorCode and errorMessage.
AxonServerQueryBus - Class in org.axonframework.axonserver.connector.query: Axon QueryBus implementation that connects to Axon Server to submit and receive queries and query responses.
AxonServerQueryBus(AxonServerQueryBus.Builder) - Constructor for class org.axonframework.axonserver.connector.query.AxonServerQueryBus: Instantiate a AxonServerQueryBus based on the fields contained in the AxonServerQueryBus.Builder.
AxonServerQueryBus.Builder - Class in org.axonframework.axonserver.connector.query: Builder class to instantiate an AxonServerQueryBus.
AxonServerQueryDispatchException - Exception in org.axonframework.axonserver.connector.query: An AxonServer Exception which is thrown on a Query Dispatching exception.
AxonServerQueryDispatchException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Initializes an AxonServer Query Dispatch Exception using the given code and errorMessage.
AxonServerQueryDispatchException(String, String) - Constructor for exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Initializes an AxonServer Query Dispatch Exception using the given code and message.
AxonServerQueryDispatchException(String, String, String, List<String>) - Constructor for exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Initializes an AxonServer Query Dispatch Exception using the given message, code, source and details .
AxonServerRegistration - Class in org.axonframework.axonserver.connector.command: Wrapper around standard Axon Framework Registration.
AxonServerRegistration(Registration, Runnable) - Constructor for class org.axonframework.axonserver.connector.command.AxonServerRegistration: Instantiate an AxonServerRegistration, which wraps the given wrappedRegistration and runs the provided closeCallback on a Registration.close() and cancel() call
AxonServerRemoteCommandHandlingException - Exception in org.axonframework.axonserver.connector.command: Exception indicating a problem that was reported by the remote end of a connection.
AxonServerRemoteCommandHandlingException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.command.AxonServerRemoteCommandHandlingException: Initialize the exception with given errorCode and errorMessage.
AxonServerRemoteCommandHandlingException(String, ErrorMessage, boolean) - Constructor for exception org.axonframework.axonserver.connector.command.AxonServerRemoteCommandHandlingException: Initialize the exception with given errorCode, errorMessage and writableStackTrace.
AxonServerRemoteQueryHandlingException - Exception in org.axonframework.axonserver.connector.query: An AxonServer Exception which is thrown on a Query Handling exception.
AxonServerRemoteQueryHandlingException(String, ErrorMessage) - Constructor for exception org.axonframework.axonserver.connector.query.AxonServerRemoteQueryHandlingException: Initialize a Query Handling exception from a remote source.
AxonServerRemoteQueryHandlingException(String, ErrorMessage, boolean) - Constructor for exception org.axonframework.axonserver.connector.query.AxonServerRemoteQueryHandlingException: Initialize a Query Handling exception from a remote source.
AxonServerSubscriptionQueryResult<I,U> - Class in org.axonframework.axonserver.connector.query.subscription: A SubscriptionQueryResult that emits initial response and update when subscription query response message is received.
AxonServerSubscriptionQueryResult(SubscriptionQueryResult, SubscriptionMessageSerializer) - Constructor for class org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult: Deprecated.
Deprecated in favor of constructor with a SpanFactory. This constructor defaults to a NoOpSpanFactory.
AxonServerSubscriptionQueryResult(SubscriptionQueryResult, SpanFactory, SubscriptionMessageSerializer) - Constructor for class org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult: Deprecated.
Deprecated in favor of constructor with a QueryBusSpanFactory. This constructor defaults to a DefaultQueryBusSpanFactory with the provided SpanFactory.
AxonServerSubscriptionQueryResult(SubscriptionQueryMessage<?, ?, ?>, SubscriptionQueryResult, SubscriptionMessageSerializer, QueryBusSpanFactory, Span) - Constructor for class org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult: Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.
axonServerSupportsQueryStreaming(List<ProcessingInstruction>) - Static method in class org.axonframework.axonserver.connector.util.ProcessingInstructionHelper: Retrieve whether Axon Server supports streaming from the given processingInstructions, by searching for the value of ProcessingKey.SERVER_SUPPORTS_STREAMING.

B

beforeStart(ClientCallStreamObserver<Object>) - Method in class org.axonframework.axonserver.connector.util.UpstreamAwareStreamObserver
build() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder: Initializes a AxonServerConfiguration as specified through this Builder.
build() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Initializes a AxonServerConnectionManager as specified through this Builder.
build() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Initializes a AxonServerCommandBus as specified through this Builder.
build() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder: Initializes a AxonServerEventScheduler as specified through this Builder.
build() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Initializes a AxonServerEventStore as specified through this Builder.
build() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Initializes an AxonServerEventStoreFactory as specified through this builder.
build() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Initializes a AxonServerQueryBus as specified through this Builder.
build(Integer, String) - Method in interface org.axonframework.axonserver.connector.event.axon.PersistentStreamScheduledExecutorBuilder: Builds a ScheduledExecutorService using the given threadCount and streamName.
build(String, PersistentStreamProperties, ScheduledExecutorService, int, String, Configuration) - Method in class org.axonframework.axonserver.connector.event.axon.DefaultPersistentStreamMessageSourceFactory: Creates a new PersistentStreamMessageSource.
build(String, PersistentStreamProperties, ScheduledExecutorService, int, String, Configuration) - Method in interface org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSourceFactory: Builds a new instance of PersistentStreamMessageSource with the specified parameters.
builder() - Static method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Instantiate a AxonServerConfiguration.Builder to create an AxonServerConfiguration.
builder() - Static method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Instantiate a Builder to be able to create an AxonServerConnectionManager.
builder() - Static method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus: Instantiate a Builder to be able to create an AxonServerCommandBus.
builder() - Static method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Instantiate a Builder to be able to create a AxonServerEventScheduler.
builder() - Static method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore: Instantiate a Builder to be able to create a AxonServerEventStore.
builder() - Static method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory: Instantiate a builder to construct an AxonServerEventStoreFactory.
builder() - Static method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus: Instantiate a Builder to be able to create an AxonServerQueryBus.
Builder() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
Builder() - Constructor for class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder
Builder() - Constructor for class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder
Builder() - Constructor for class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder
Builder() - Constructor for class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder
Builder() - Constructor for class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder
Builder() - Constructor for class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder
buildQuerySerializer() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Build a QuerySerializer using the configured messageSerializer, genericSerializer and configuration.
buildSerializer() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Build a CommandSerializer using the configured serializer and configuration.
buildSubscriptionMessageSerializer() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Build a SubscriptionMessageSerializer using the configured messageSerializer, genericSerializer and configuration.

C

call() - Method in class org.axonframework.axonserver.connector.PriorityCallable
cancel() - Method in class org.axonframework.axonserver.connector.command.AxonServerRegistration
cancel() - Method in class org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult
cancel() - Method in class org.axonframework.axonserver.connector.query.subscription.DeserializedResult: Deprecated.
cancel() - Method in class org.axonframework.axonserver.connector.query.subscription.DisposableResult: Deprecated.
cancel(boolean) - Method in interface org.axonframework.axonserver.connector.util.Scheduler.ScheduledTask: Cancels the scheduled registration.
cancelSchedule(ScheduleToken) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Cancel a scheduled event.
canSerializeTo(Class<T>) - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
channelCustomizer(UnaryOperator<ManagedChannelBuilder<?>>) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Registers the given channelCustomization, which configures the underling ManagedChannelBuilder used to set up connections to AxonServer.
classForType(SerializedType) - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
clientId() - Method in class org.axonframework.axonserver.connector.TopologyChange: Returns the client identifier for which a TopologyChange occurred.
clientId(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
clientStreamId() - Method in class org.axonframework.axonserver.connector.TopologyChange: Returns the client stream identifier for which a TopologyChange occurred.
clientSupportsQueryStreaming(List<ProcessingInstruction>) - Static method in class org.axonframework.axonserver.connector.util.ProcessingInstructionHelper: Retrieve whether Client (query issuer) supports streaming from the given processingInstructions, by searching for the value of ProcessingKey.CLIENT_SUPPORTS_STREAMING.
close() - Method in class org.axonframework.axonserver.connector.event.axon.EventBuffer
close() - Method in class org.axonframework.axonserver.connector.event.axon.PersistentStreamConnection: Closes the persistent stream connection to Axon Server.
close() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResultStreamAdapter
code() - Method in exception org.axonframework.axonserver.connector.AxonServerException
code() - Method in exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Return a String defining the error code.
COMMAND_DISPATCH_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
COMMAND_EXECUTION_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
COMMAND_EXECUTION_NON_TRANSIENT_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
COMMAND_HANDLER_ADDED - Enum constant in enum class org.axonframework.axonserver.connector.TopologyChange.Type: A change type signalling a command handler was added.
COMMAND_HANDLER_REMOVED - Enum constant in enum class org.axonframework.axonserver.connector.TopologyChange.Type: A change type signalling a command handler was removed.
commandFlowControl(int, int, int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
commandInProgressAwait(Duration) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the duration to wait for in-progress command handlers to complete during shutdown.
commandLoadFactor(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
CommandLoadFactorProvider - Interface in org.axonframework.axonserver.connector.command: Provides the load factor value of the client for the specific command.
CommandPriorityCalculator - Interface in org.axonframework.axonserver.connector.command: Calculate the priority of CommandMessage based on its content.
CommandSerializer - Class in org.axonframework.axonserver.connector.command: Converter between Axon Framework CommandMessages and Axon Server gRPC Command messages.
CommandSerializer(Serializer, AxonServerConfiguration) - Constructor for class org.axonframework.axonserver.connector.command.CommandSerializer: Instantiate a serializer used to convert Axon CommandMessages and CommandResultMessages into Axon Server gRPC messages and vice versa.
compareTo(PriorityTask) - Method in interface org.axonframework.axonserver.connector.PriorityTask
completeRequestStream() - Method in class org.axonframework.axonserver.connector.util.UpstreamAwareStreamObserver: Completes the request steam related to this stream observer.
componentName() - Method in class org.axonframework.axonserver.connector.TopologyChange: Returns the component name for which a TopologyChange occurred.
componentName(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
CONCURRENCY_EXCEPTION - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
configuration(AxonServerConfiguration) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: 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.
configuration(AxonServerConfiguration) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the AxonServerConfiguration describing the servers to connect with and how to manage flow control.
configuration(AxonServerConfiguration) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the AxonServerConfiguration describing the servers to connect with and how to manage flow control.
configuration(AxonServerConfiguration) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: 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.
configureModule(Configurer) - Method in class org.axonframework.axonserver.connector.ServerConnectorConfigurerModule
CONNECTION_FAILED - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
connectionManager(AxonServerConnectionManager) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder: Sets the AxonServerConnectionManager used to create connections between this application and an Axon Server instance.
connectionManager(AxonServerConnectionManager) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the AxonServerConnectionManager managing the connections to Axon Server.
ConnectionManager - Interface in org.axonframework.axonserver.connector: Interface describing functionality for connection managers.
connections() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager
connections() - Method in interface org.axonframework.axonserver.connector.ConnectionManager: Return the connections this instances manages.
ConnectionSanityChecker - Interface in org.axonframework.axonserver.connector.heartbeat: Deprecated.
in through use of the AxonServer java connector
connectTimeout(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
constructFor(String) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory: Constructs an AxonServerEventStore connected to the given context.
constructFor(String, AxonServerEventStoreFactory.AxonServerEventStoreConfiguration) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory: Constructs an AxonServerEventStore connected to the given context with customization based on the given configuration.
context - Variable in class org.axonframework.axonserver.connector.processor.EventProcessorControlService
context() - Method in class org.axonframework.axonserver.connector.TopologyChange: Returns the context for which a TopologyChange occurred.
context(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
ContextAddingInterceptor - Class in org.axonframework.axonserver.connector.util: Deprecated.
in through use of the AxonServer java connector
ContextAddingInterceptor(String) - Constructor for class org.axonframework.axonserver.connector.util.ContextAddingInterceptor: Deprecated.

Constructs a ContextAddingInterceptor to attach the given context.
convert(ErrorMessage) - Method in enum class org.axonframework.axonserver.connector.ErrorCode: Converts the errorMessage to the relevant AxonException
convert(ErrorMessage, Supplier<Object>) - Method in enum class org.axonframework.axonserver.connector.ErrorCode: Converts the errorMessage to the relevant AxonException
convert(String, Throwable) - Method in enum class org.axonframework.axonserver.connector.ErrorCode: Converts the source and the throwable to the relevant AxonException
convert(Throwable) - Method in enum class org.axonframework.axonserver.connector.ErrorCode: Converts the throwable to the relevant AxonException
convert(Map<String, MetaDataValue>) - Method in class org.axonframework.axonserver.connector.util.GrpcMetaDataConverter: Convert the given Map of MetaDataValues to a Map containing the Java representations of each of those values.
convertFromMetaDataValue(MetaDataValue) - Method in class org.axonframework.axonserver.connector.util.GrpcMetaDataConverter: Convert the given MetaDataValue to its Java representation.
convertToMetaDataValue(Object) - Method in class org.axonframework.axonserver.connector.util.GrpcMetaDataConverter: Convert the given value into a MetaDataValue, attempting to maintain the source type as much as possible in the returned MetaDataValue.
create(Configuration) - Method in class org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSourceDefinition
createStreamableMessageSourceForContext(String) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore: Creates a StreamableMessageSource that streams events from the given context, rather than the default context the application was configured to connect to.

D

DATAFILE_READ_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
DATAFILE_WRITE_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
decrypt(Event) - Method in class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.
decrypt(EventWithToken) - Method in class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.
decryptBytes(int, byte[]) - Method in class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.
DEFAULT_VALUE - Static variable in interface org.axonframework.axonserver.connector.command.CommandLoadFactorProvider: The default value for command load factor: 100.
defaultCommandCallback(CommandCallback<Object, Object>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the callback to use when commands are dispatched in a "fire and forget" method, such as AxonServerCommandBus.dispatch(CommandMessage).
defaultCommandExecutorServiceBuilder() - Static method in interface org.axonframework.axonserver.connector.util.ExecutorServiceBuilder: Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming commands.
defaultCommandPriorityCalculator() - Static method in interface org.axonframework.axonserver.connector.command.CommandPriorityCalculator: Returns a default implementation of the CommandPriorityCalculator, always returning priority 0.
defaultContext(String) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the default context for this command bus to connect to.
defaultContext(String) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder: Sets the default context for this event scheduler to connect to.
defaultContext(String) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the default context for this event store to connect to.
defaultContext(String) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the default context for this event store to connect to.
defaultFactory() - Static method in interface org.axonframework.axonserver.connector.event.axon.PersistentStreamScheduledExecutorBuilder: Default PersistentStreamScheduledExecutorBuilder.
DefaultHandlers<Case,Handler> - Class in org.axonframework.axonserver.connector: Deprecated.
in through use of the AxonServer java connector
DefaultHandlers() - Constructor for class org.axonframework.axonserver.connector.DefaultHandlers: Deprecated.
DefaultInstructionAckSource<T> - Class in org.axonframework.axonserver.connector: Default implementation of InstructionAckSource.
DefaultInstructionAckSource(Function<InstructionAck, T>) - Constructor for class org.axonframework.axonserver.connector.DefaultInstructionAckSource: Instantiates DefaultInstructionAckSource.
DefaultPersistentStreamMessageSourceFactory - Class in org.axonframework.axonserver.connector.event.axon: Default implementation of the PersistentStreamMessageSourceFactory that creates PersistentStreamMessageSource instances.
DefaultPersistentStreamMessageSourceFactory() - Constructor for class org.axonframework.axonserver.connector.event.axon.DefaultPersistentStreamMessageSourceFactory
defaultQueryExecutorServiceBuilder() - Static method in interface org.axonframework.axonserver.connector.util.ExecutorServiceBuilder: Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming queries.
defaultQueryPriorityCalculator() - Static method in interface org.axonframework.axonserver.connector.query.QueryPriorityCalculator: Returns a default implementation of the QueryPriorityCalculator, always returning priority 0.
defaultQueryResponseExecutorServiceBuilder() - Static method in interface org.axonframework.axonserver.connector.util.ExecutorServiceBuilder: Create a default ExecutorServiceBuilder used to create a ThreadPoolExecutor for processing incoming query responses.
describe(StreamingEventProcessor) - Static method in class org.axonframework.axonserver.connector.processor.StreamingEventProcessorInfoMessage: Create an EventProcessorInfo based on the given eventProcessor.
deserialize(Command) - Method in class org.axonframework.axonserver.connector.command.CommandSerializer: Convert a Command into a CommandMessage.
deserialize(CommandResponse) - Method in class org.axonframework.axonserver.connector.command.CommandSerializer: Convert a CommandResponse into a CommandResultMessage.
deserialize(QueryResponse) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Deserializes the given queryResponse into a QueryResponseMessage.
deserialize(QueryUpdate) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Deserializes the given queryUpdate into a SubscriptionQueryUpdateMessage.
deserialize(SubscriptionQuery) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Deserializes the given subscriptionQuery into a SubscriptionQueryMessage.
deserialize(SerializedObject<S>) - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
DeserializedResult<I,U> - Class in org.axonframework.axonserver.connector.query.subscription: Deprecated.
in through use of the AxonServer java connector
DeserializedResult(SubscriptionQueryResult<QueryResponse, QueryUpdate>, SubscriptionMessageSerializer) - Constructor for class org.axonframework.axonserver.connector.query.subscription.DeserializedResult: Deprecated.

Instantiate a DeserializedResult wrapping the delegate which will be serialized by the given serializer.
deserializeRequest(QueryRequest) - Method in class org.axonframework.axonserver.connector.query.QuerySerializer: Convert a QueryRequest into a QueryMessage.
deserializeResponse(QueryResponse) - Method in class org.axonframework.axonserver.connector.query.QuerySerializer: Converts a QueryResponse into a QueryResponseMessage.
deserializeResponse(QueryResponse, ResponseType<R>) - Method in class org.axonframework.axonserver.connector.query.QuerySerializer: Convert a QueryResponse into a QueryResponseMessage.
details() - Method in exception org.axonframework.axonserver.connector.AxonServerException
details() - Method in exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Return a List of Strings, each describing a single "cause".
determinePriority(CommandMessage<?>) - Method in interface org.axonframework.axonserver.connector.command.CommandPriorityCalculator: Determines the priority of the given command.
determinePriority(QueryMessage<?, ?>) - Method in interface org.axonframework.axonserver.connector.query.QueryPriorityCalculator: Determines the priority of the given query.
DIRECTORY_CREATION_FAILED - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
disconnect() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Disconnects any active connections, forcing a new connection to be established when one is requested.
disconnect() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus: Disconnect the command bus for receiving commands from Axon Server, by unsubscribing all registered command handlers.
disconnect() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus: Disconnect the query bus from Axon Server, by unsubscribing all known query handlers and aborting all queries in progress.
disconnect(String) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Disconnects any active connection for the given context, forcing a new connection to be established when one is requested.
dispatch(CommandMessage<C>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
dispatch(CommandMessage<C>, CommandCallback<? super C, ? super R>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
DispatchInterceptors<M extends org.axonframework.messaging.Message<?>> - Class in org.axonframework.axonserver.connector: Composite of MessageDispatchInterceptors that apply all interceptors in the order of registration.
DispatchInterceptors() - Constructor for class org.axonframework.axonserver.connector.DispatchInterceptors
DisposableResult<I,U> - Class in org.axonframework.axonserver.connector.query.subscription: Deprecated.
in through use of the AxonServer java connector
DisposableResult(SubscriptionQueryResult<I, U>, Registration) - Constructor for class org.axonframework.axonserver.connector.query.subscription.DisposableResult: Deprecated.

Instantiate a DisposableResult wrapping the delegate, opening up the capability to DisposableResult.cancel() it.

E

enabledLocalSegmentShortCut() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Enables shortcut to local QueryBus.
encrypt(Event) - Method in class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.
encryptBytes(int, byte[]) - Method in class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.
equals(Object) - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
equals(Object) - Method in class org.axonframework.axonserver.connector.PriorityCallable
equals(Object) - Method in class org.axonframework.axonserver.connector.PriorityRunnable
equals(Object) - Method in class org.axonframework.axonserver.connector.TopologyChange
equals(Object) - Method in class org.axonframework.axonserver.connector.TopologyChange.HandlerSubscription
equals(Object) - Method in class org.axonframework.axonserver.connector.util.GrpcMetaDataConverter
errorCode() - Method in exception org.axonframework.axonserver.connector.AxonServerException
errorCode() - Method in enum class org.axonframework.axonserver.connector.ErrorCode
errorCode() - Method in exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Return an ErrorCode based on the AxonServerQueryDispatchException.code().
ErrorCode - Enum Class in org.axonframework.axonserver.connector: Converts an Axon Server Error to the relevant Axon framework exception.
EVENT_PAYLOAD_TOO_LARGE - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
EventBuffer - Class in org.axonframework.axonserver.connector.event.axon: Client-side buffer of messages received from the server.
EventBuffer(EventStream, EventUpcaster, Serializer, boolean) - Constructor for class org.axonframework.axonserver.connector.event.axon.EventBuffer: Initializes an Event Buffer, passing messages through given upcasterChain and deserializing events using given serializer.
eventCipher(EventCipher) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder: Deprecated.
Through use of the Axon Server Java Connector project.
EventCipher - Class in org.axonframework.axonserver.connector.event.util: Deprecated.
in through use of the AxonServer java connector
EventCipher() - Constructor for class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.

Constructs a default EventCipher.
EventCipher(byte[]) - Constructor for class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.

Constructs a EventCipher using the given secretKey.
EventCipher(Function<Event, Integer>, List<byte[]>) - Constructor for class org.axonframework.axonserver.connector.event.util.EventCipher: Deprecated.
eventFlowControl(int, int, int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
Eventhandling() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling
eventProcessingConfiguration - Variable in class org.axonframework.axonserver.connector.processor.EventProcessorControlService
EventProcessorControlService - Class in org.axonframework.axonserver.connector.processor: Service that listens to PlatformOutboundInstructions to control EventProcessors when for example requested by Axon Server.
EventProcessorControlService(AxonServerConnectionManager, EventProcessingConfiguration, String) - Constructor for class org.axonframework.axonserver.connector.processor.EventProcessorControlService: Deprecated.
Please use EventProcessorControlService(AxonServerConnectionManager, EventProcessingConfiguration, String, Map) to ensure processor settings are provided.
EventProcessorControlService(AxonServerConnectionManager, EventProcessingConfiguration, String, Map<String, AxonServerConfiguration.Eventhandling.ProcessorSettings>) - Constructor for class org.axonframework.axonserver.connector.processor.EventProcessorControlService: Initialize a EventProcessorControlService.
EventProcessorControlService(AxonServerConnectionManager, EventProcessingConfiguration, AxonServerConfiguration) - Constructor for class org.axonframework.axonserver.connector.processor.EventProcessorControlService: Initialize a EventProcessorControlService.
EventProcessorControlService.AxonProcessorInstructionHandler - Class in org.axonframework.axonserver.connector.processor
EventProcessorInfoConfiguration - Class in org.axonframework.axonserver.connector.event.axon: Module Configuration implementation that defines the components needed to control and monitor the EventProcessors with AxonServer.
EventProcessorInfoConfiguration() - Constructor for class org.axonframework.axonserver.connector.event.axon.EventProcessorInfoConfiguration: Create an default EventProcessorInfoConfiguration, which uses the Configuration as a means to retrieve the EventProcessingConfiguration, AxonServerConnectionManager and AxonServerConfiguration.
EventProcessorInfoConfiguration(Function<Configuration, EventProcessorControlService>) - Constructor for class org.axonframework.axonserver.connector.event.axon.EventProcessorInfoConfiguration: Create a default EventProcessorInfoConfiguration, which uses the EventProcessorControlService
EventProcessorInfoConfiguration(Function<Configuration, EventProcessingConfiguration>, Function<Configuration, AxonServerConnectionManager>, Function<Configuration, AxonServerConfiguration>) - Constructor for class org.axonframework.axonserver.connector.event.axon.EventProcessorInfoConfiguration: Creates an EventProcessorInfoConfiguration using the provided functions to retrieve the EventProcessingConfiguration, AxonServerConnectionManager and AxonServerConfiguration.
eventSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder: Sets the Serializer used to de-/serialize events.
eventSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the Serializer used to serialize and deserialize the Event Message's payload and Meta Data with.
eventSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the Serializer used to de-/serialize the event payload and meta data with.
EventStoreClientException - Exception in org.axonframework.axonserver.connector.event.util: Deprecated.
in through use of the AxonServer java connector
EventStoreClientException(String, String) - Constructor for exception org.axonframework.axonserver.connector.event.util.EventStoreClientException: Deprecated.

Constructs a EventStoreClientException using the given code and message.
EventStoreClientException(String, String, Throwable) - Constructor for exception org.axonframework.axonserver.connector.event.util.EventStoreClientException: Deprecated.

Constructs a EventStoreClientException using the given code, message and cause.
EventStoreConfiguration() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.EventStoreConfiguration
ExceptionSerializer - Class in org.axonframework.axonserver.connector.util: Utility class used to serializer Throwables into ErrorMessages.
execute(Runnable) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
executorServiceBuilder(ExecutorServiceBuilder) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the ExecutorServiceBuilder which builds an ExecutorService based on a given AxonServerConfiguration and BlockingQueue of Runnable.
executorServiceBuilder(ExecutorServiceBuilder) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Deprecated.
in favor of using the AxonServerQueryBus.Builder.queryExecutorServiceBuilder(ExecutorServiceBuilder) method
ExecutorServiceBuilder - Interface in org.axonframework.axonserver.connector.util: A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.

F

flowControl(int, int, int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
FlowControlConfiguration(Integer, Integer, Integer) - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Construct a AxonServerConfiguration.FlowControlConfiguration.
FlowControllingStreamObserver<T> - Class in org.axonframework.axonserver.connector.util: Deprecated.
in through use of the AxonServer java connector
FlowControllingStreamObserver(StreamObserver<T>, String, AxonServerConfiguration.FlowControlConfiguration, Function<FlowControl, T>, Predicate<T>) - Constructor for class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.

Constructs a FlowControllingStreamObserver.
FlowControllingStreamObserver(StreamObserver<T>, AxonServerConfiguration, Function<FlowControl, T>, Predicate<T>) - Constructor for class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.

Constructs a FlowControllingStreamObserver.
forceReadFromLeader(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
forPriority(ExecutorService, long, AtomicLong) - Static method in interface org.axonframework.axonserver.connector.util.PriorityTaskSchedulers: Creates a Scheduler that is compatible with an ExecutorService that needs tasks that are submitted to be a PriorityTask so that they can be prioritized.
FULL_CONCURRENCY_POLICY - Static variable in class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider: A String constant representing the full concurrency policy.

G

genericSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the generic Serializer used to de-/serialize incoming and outgoing query ResponseType implementations.
get() - Method in class org.axonframework.axonserver.connector.util.GrpcMetaData
get(String) - Method in class org.axonframework.axonserver.connector.event.axon.QueryResult: Retrieve the column information referring to the given name.
get(String, Case) - Method in class org.axonframework.axonserver.connector.DefaultHandlers: Deprecated.
get(String, Case) - Method in interface org.axonframework.axonserver.connector.Handlers: Gets all handlers that match given context and requestCase.
getAggregateIdentifier() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getAutoPersistentStreamsSettings() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Return the settings for all persistent streams that will be created automatically.
getBatchSize() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: The maximum number of events to process in a single transaction when reading a persistent stream.
getCertFile() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The path to the certificate file used for SSL.
getChannel() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Deprecated.
getChannel(String) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Deprecated.
getClientId() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The client identifier as it registers itself to Axon Server, must be unique.
getCode() - Method in exception org.axonframework.axonserver.connector.event.util.EventStoreClientException: Deprecated.

Returns the error code of this exception.
getColumns() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResult: The list of columns returned by the query.
getCommandExecutionErrorCode(Throwable) - Static method in enum class org.axonframework.axonserver.connector.ErrorCode: Returns an Command Execution ErrorCode variation based on the transiency of the given Throwable
getCommandFlowControl() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Specific flow control settings for the command message stream.
getCommandLoadFactor() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: An int representing the fixed value of load factor sent to Axon Server for any command's subscription if no specific implementation of CommandLoadFactorProvider is configured.
getCommandName() - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
getCommandThreads() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The number of threads executing commands.
getCommitTimeout() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The timeout (in milliseconds) to wait for response on commit.
getComponentName() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The name of this application.
getConnection() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Retrieves the AxonServerConnection used for the default context of this application.
getConnection(String) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Retrieves the AxonServerConnection used for the given context of this application.
getConnectionManagementThreadPoolSize() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The number of threads that should be used for connection management activities by the AxonServerConnectionFactory used by the AxonServerConnectionManager.
getConnectTimeout() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: A value representing the maximum time in milliseconds a request for the initial Axon Server connection may last.
getContentType() - Method in class org.axonframework.axonserver.connector.util.GrpcSerializedObject
getContext() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The bounded context that this application operates in.
getConverter() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
getData() - Method in class org.axonframework.axonserver.connector.util.GrpcSerializedObject
getDefaultContext() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Returns the name of the default context of this application.
getDefaultFlowControlConfiguration() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The default flow control settings used when no specific command, event, or query flow control settings are provided.
getErrorCode() - Method in exception org.axonframework.axonserver.connector.command.AxonServerCommandDispatchException: Returns the error code as reported by the server.
getErrorCode() - Method in exception org.axonframework.axonserver.connector.command.AxonServerNonTransientRemoteCommandHandlingException: Returns the error code as reported by the server.
getErrorCode() - Method in exception org.axonframework.axonserver.connector.command.AxonServerRemoteCommandHandlingException: Returns the error code as reported by the server.
getErrorCode() - Method in exception org.axonframework.axonserver.connector.query.AxonServerNonTransientRemoteQueryHandlingException: Returns the error code as reported by the server.
getErrorCode() - Method in exception org.axonframework.axonserver.connector.query.AxonServerRemoteQueryHandlingException: Return a String defining the error code.
getEventCipher() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
Through use of the Axon Server Java Connector project.
getEventFlowControl() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Specific flow control settings for the event message stream.
getEventhandling() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Return the configured AxonServerConfiguration.Eventhandling of this application for Axon Server.
getEventIdentifier() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getEventStoreConfiguration() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Return the configured AxonServerConfiguration.EventStoreConfiguration of this application for Axon Server.
getExceptionDescriptions() - Method in exception org.axonframework.axonserver.connector.command.AxonServerCommandDispatchException: Returns a List of Strings describing the remote exception.
getFilter() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Expression to filter out events in a persistent stream, using Axon Server Query Language as its syntax.
getFor(String) - Method in interface org.axonframework.axonserver.connector.command.CommandLoadFactorProvider: Returns the load factor value for the specific command
getFromCode(String) - Static method in enum class org.axonframework.axonserver.connector.ErrorCode
getHeartbeat() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The configuration specifics on sending heartbeat messages to ensure a fully operational end-to-end connection with Axon Server.
getIdentifier() - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
getIdentifier() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
getIdentifier() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
getIdentifier() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
getIdentifiers() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResult: Returns the identifiers that uniquely identify this result entry.
getInitialNrOfPermits() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Deprecated.
In favor of AxonServerConfiguration.FlowControlConfiguration.getPermits().
getInitialNrOfPermits() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
In favor of AxonServerConfiguration.getPermits()
getInitialPosition() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: The initial token position for the persistent stream.
getInitialSegmentCount() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: The number of segments for the persistent stream if it needs to be created.
getInterval() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration: The interval between consecutive heartbeat message sent in milliseconds.
getKeepAliveTime() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The interval (in ms) for keep alive requests, 0 is keep-alive disabled.
getKeepAliveTimeout() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The timeout (in ms) for keep alive requests.
getLoadBalancingStrategy() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling.ProcessorSettings: Returns the load balancing strategy for this event processor.
getMaxGrpcBufferedMessages() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
This property is no longer used through adjustments in the Axon Server Java Connector project.
getMaxMessageSize() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The gRPC max inbound message size.
getMaxMessageSizeWarningThreshold() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The threshold (in percentage of 0-1) of the max message size at which a warning should be logged.
getMetaData() - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
getMetaData() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getMetaData() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
getMetaData() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
getMetaData() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
getName() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: The name for the persistent stream.
getNewPermitsThreshold() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: The threshold at which the application sends new permits to server.
getNewPermitsThreshold() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The threshold at which the application sends new permits to server.
getNrOfNewPermits() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Additional number of permits send for message streams (events, commands, queries) when application is ready for more messages.
getNrOfNewPermits() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Additional number of permits send for message streams (events, commands, queries) when application is ready for more messages.
getOrDefault(String, Case, Collection<Handler>) - Method in interface org.axonframework.axonserver.connector.Handlers: The same as Handlers.get(String, Object) but if no handler is found it returns provided def collection of handlers.
getOriginServer() - Method in exception org.axonframework.axonserver.connector.command.AxonServerRemoteCommandHandlingException: Returns the name of the server that reported the error.
getPayload() - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
getPayload() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getPayload() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
getPayload() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
getPayload() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
getPayloadType() - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
getPayloadType() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
getPayloadType() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
getPayloadType() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
getPermits() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: The initial number of permits send for message streams (events, commands, queries).
getPermits() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The initial number of permits send for message streams (events, commands, queries).
getPersistentStreams() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Returns the settings for each of the configured persistent streams, by name.
getProcessors() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling: Returns the settings for each of the configured processors, by name.
getProcessorsNotificationInitialDelay() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The initial delay (in ms.) before application sends first status update on event processors to Axon Server.
getProcessorsNotificationRate() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The interval (in ms.) application sends status updates on event processors to Axon Server.
getQueryExecutionErrorCode(Throwable) - Static method in enum class org.axonframework.axonserver.connector.ErrorCode: Returns an Query Execution ErrorCode variation based on the transiency of the given Throwable
getQueryFlowControl() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Specific flow control settings for the query message stream.
getQueryName() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
getQueryName() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
getQueryResponseThreads() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The number of threads executing query responses.
getQueryResultEntry() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResult: Returns the wrapped entry as returned by the AxonServer Java Connector.
getQueryThreads() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The number of threads executing queries.
getReconnectInterval() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The amount of time in milliseconds to wait in between attempts to connect to Axon Server.
getRequestStream() - Method in class org.axonframework.axonserver.connector.util.UpstreamAwareStreamObserver: Returns the request stream observer which allows interaction with the client stream.
getResponseType() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
getResponseType() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
getSequenceNumber() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getSequencingPolicy() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: The sequencing policy to use for the persistent stream.
getSequencingPolicyParameters() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Parameters specified for the sequencing policy.
getServer() - Method in exception org.axonframework.axonserver.connector.command.AxonServerCommandDispatchException: Returns the name of the server that reported the error.
getServer() - Method in exception org.axonframework.axonserver.connector.command.AxonServerNonTransientRemoteCommandHandlingException: Returns the name of the server that reported the error.
getServer() - Method in exception org.axonframework.axonserver.connector.query.AxonServerNonTransientRemoteQueryHandlingException: Returns the name of the server that reported the error.
getServer() - Method in exception org.axonframework.axonserver.connector.query.AxonServerRemoteQueryHandlingException: Return a String defining the location where the error originated.
getServers() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Comma separated list of Axon Server servers.
getSnapshotPrefetch() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: An int indicating the maximum number of Aggregate snapshots which will be retrieved.
getSortValues() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResult: Returns the list of values to use to compare the order of this entry to other entries.
getSuppressDownloadMessage() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.
getThreadCount() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: The number of threads used to process tasks (e.g. event handling) for the persistent stream.
getTimeout() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration: The time window within which a response is expected in milliseconds.
getTimestamp() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getToken() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The token providing access control with Axon Server
getType() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
getType() - Method in class org.axonframework.axonserver.connector.util.GrpcSerializedObject
getUpdateResponseType() - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage
GRPC_MESSAGE_TOO_LARGE - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
GrpcBackedCommandMessage<C> - Class in org.axonframework.axonserver.connector.command: Wrapper that allows clients to access a gRPC Command as a CommandMessage.
GrpcBackedCommandMessage(Command, Serializer) - Constructor for class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage: Instantiate a GrpcBackedCommandMessage with the given command and using the provided Serializer to be able to retrieve the payload and MetaData from it.
GrpcBackedDomainEventData - Class in org.axonframework.axonserver.connector.event.axon: DomainEventData implementation that retrieves its raw data from a protobuf Event message.
GrpcBackedDomainEventData(Event) - Constructor for class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData: Initialize using the given event as the source of raw data.
GrpcBackedQueryMessage<Q,R> - Class in org.axonframework.axonserver.connector.query: Wrapper that allows clients to access a gRPC QueryRequest as a QueryMessage.
GrpcBackedQueryMessage(QueryRequest, Serializer, Serializer) - Constructor for class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage: Instantiate a GrpcBackedResponseMessage with the given queryRequest, using the provided messageSerializer to be able to retrieve the payload and MetaData from it.
GrpcBackedResponseMessage<R> - Class in org.axonframework.axonserver.connector.query: Wrapper that allows clients to access a gRPC QueryResponse as a QueryResponseMessage.
GrpcBackedResponseMessage(QueryResponse, Serializer) - Constructor for class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage: Instantiate a GrpcBackedResponseMessage with the given queryResponse, using the provided Serializer to be able to retrieve the payload and MetaData from it.
GrpcBackedSubscriptionQueryMessage<Q,I,U> - Class in org.axonframework.axonserver.connector.query.subscription: Wrapper that allows clients to access a gRPC SubscriptionQuery message as a SubscriptionQueryMessage.
GrpcBackedSubscriptionQueryMessage(SubscriptionQuery, Serializer, Serializer) - Constructor for class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage: Instantiate a GrpcBackedSubscriptionQueryMessage with the given subscriptionQuery, using the provided messageSerializer to be able to retrieve the payload and MetaData from it.
GrpcBufferingInterceptor - Class in org.axonframework.axonserver.connector.util: Deprecated.
in through use of the AxonServer java connector
GrpcBufferingInterceptor(int) - Constructor for class org.axonframework.axonserver.connector.util.GrpcBufferingInterceptor: Deprecated.

Initialize the interceptor to ask for additionalBuffer amount of messages from the server.
GrpcExceptionParser - Class in org.axonframework.axonserver.connector.event.util: Converts GRPC Exceptions to RuntimeExceptions.
GrpcExceptionParser() - Constructor for class org.axonframework.axonserver.connector.event.util.GrpcExceptionParser
GrpcHeartbeatSource - Class in org.axonframework.axonserver.connector.heartbeat.source: Deprecated.
in through use of the AxonServer java connector
GrpcHeartbeatSource(AxonServerConnectionManager, String) - Constructor for class org.axonframework.axonserver.connector.heartbeat.source.GrpcHeartbeatSource: Deprecated.

Creates a GrpcHeartbeatSource which uses an AxonServerConnectionManager to send heartbeats messages to AxonServer.
GrpcMessageSizeExceededException - Exception in org.axonframework.axonserver.connector.util: Exception thrown when a message exceeds the maximum allowed size.
GrpcMessageSizeExceededException(String) - Constructor for exception org.axonframework.axonserver.connector.util.GrpcMessageSizeExceededException: Creates a new exception that indicates the gRPC message size has been exceeded with the given message.
GrpcMessageSizeInterceptor - Class in org.axonframework.axonserver.connector.util: Interceptor around a gRPC request that checks whether the message size is within the limits of the server.
GrpcMessageSizeInterceptor(int, double) - Constructor for class org.axonframework.axonserver.connector.util.GrpcMessageSizeInterceptor
GrpcMessageSizeWarningThresholdReachedException - Exception in org.axonframework.axonserver.connector.util: Exception created to log a warning when a message size exceeds a certain threshold.
GrpcMessageSizeWarningThresholdReachedException() - Constructor for exception org.axonframework.axonserver.connector.util.GrpcMessageSizeWarningThresholdReachedException: Creates a new instance of the exception indicating that the message size has exceeded the threshold.
GrpcMetaData - Class in org.axonframework.axonserver.connector.util: Implementation that provides access to a Map of gRPC MetaDataValues in the form of MetaData.
GrpcMetaData(Map<String, MetaDataValue>, Serializer) - Constructor for class org.axonframework.axonserver.connector.util.GrpcMetaData: Instantiate a wrapper around the given metaDataValues providing access to them as a MetaData object.
GrpcMetaDataAwareSerializer - Class in org.axonframework.axonserver.connector.event.axon: Wrapper around standard Axon Framework serializer that can deserialize Metadata from AxonServer events.
GrpcMetaDataAwareSerializer(Serializer) - Constructor for class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer: Constructs a GrpcMetaDataAwareSerializer, using the given delegate to delegate serialization to
GrpcMetaDataConverter - Class in org.axonframework.axonserver.connector.util: Utility class for converting gRPC MetaData entries into a Java Map and vice versa.
GrpcMetaDataConverter(Serializer) - Constructor for class org.axonframework.axonserver.connector.util.GrpcMetaDataConverter: Initialize the converter, using the given serializer to serialize Objects.
GrpcMetadataSerializer - Class in org.axonframework.axonserver.connector.util: Mapping that translates a MetaData into a map of GRPC MetaDataValue.
GrpcMetadataSerializer(GrpcMetaDataConverter) - Constructor for class org.axonframework.axonserver.connector.util.GrpcMetadataSerializer: Constructs a GrpcMetadataSerializer using the given metaDataConverter.
GrpcObjectSerializer<O> - Class in org.axonframework.axonserver.connector.util: Mapping that translates an object into a GRPC SerializedObject.
GrpcObjectSerializer(Serializer) - Constructor for class org.axonframework.axonserver.connector.util.GrpcObjectSerializer: Constructs a GrpcObjectSerializer using the given serializer to serialize the payload and type of given objects with.
GrpcObjectSerializer.Serializer<A> - Interface in org.axonframework.axonserver.connector.util: Contract towards serializing an object of type A.
GrpcPayloadSerializer - Class in org.axonframework.axonserver.connector.util: Mapping that translates a Message into a GRPC SerializedObject.
GrpcPayloadSerializer(Serializer) - Constructor for class org.axonframework.axonserver.connector.util.GrpcPayloadSerializer: Constructs a GrpcPayloadSerializer using the given serializer to serialize messages with
GrpcSerializedObject - Class in org.axonframework.axonserver.connector.util: Wrapper that allows clients to access a gRPC SerializedObject message as a SerializedObject.
GrpcSerializedObject(SerializedObject) - Constructor for class org.axonframework.axonserver.connector.util.GrpcSerializedObject: Initialize a GrpcSerializedObject, wrapping a SerializedObject as a SerializedObject.

H

handler() - Method in class org.axonframework.axonserver.connector.TopologyChange: Returns the HandlerSubscription for which a TopologyChange occurred.
Handlers<Case,Handler> - Interface in org.axonframework.axonserver.connector: Handler registry - gives possibility of registering handlers for specific cases and contexts.
HandlerSubscription(String, Integer) - Constructor for class org.axonframework.axonserver.connector.TopologyChange.HandlerSubscription: Constructs a HandlerSubscription for the given name and loadFactor.
handleSnapshotReadingError(String, Throwable) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore
hashCode() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
hashCode() - Method in class org.axonframework.axonserver.connector.PriorityCallable
hashCode() - Method in class org.axonframework.axonserver.connector.PriorityRunnable
hashCode() - Method in class org.axonframework.axonserver.connector.TopologyChange.HandlerSubscription
hashCode() - Method in class org.axonframework.axonserver.connector.TopologyChange
hashCode() - Method in class org.axonframework.axonserver.connector.util.GrpcMetaDataConverter
hasNext() - Method in interface org.axonframework.axonserver.connector.event.axon.QueryResultStream: Validates whether there is a following entry in this stream to consume.
hasNext(int, TimeUnit) - Method in interface org.axonframework.axonserver.connector.event.axon.QueryResultStream: Validates whether there is a following entry in this stream to consume.
hasNext(int, TimeUnit) - Method in class org.axonframework.axonserver.connector.event.axon.QueryResultStreamAdapter
hasNextAvailable(int, TimeUnit) - Method in class org.axonframework.axonserver.connector.event.axon.EventBuffer
HeartbeatConfiguration - Class in org.axonframework.axonserver.connector.heartbeat: Deprecated.
in through use of the AxonServer java connector
HeartbeatConfiguration() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration
HeartbeatConfiguration() - Constructor for class org.axonframework.axonserver.connector.heartbeat.HeartbeatConfiguration: Deprecated.

Default constructor for HeartbeatConfiguration, that uses Configuration in order to retrieve the registered AxonServerConnectionManager and AxonServerConfiguration.
HeartbeatConfiguration(Function<Configuration, AxonServerConnectionManager>, Function<Configuration, AxonServerConfiguration>) - Constructor for class org.axonframework.axonserver.connector.heartbeat.HeartbeatConfiguration: Deprecated.

Creates a HeartbeatConfiguration using the provided functions to retrieve the AxonServerConnectionManager and AxonServerConfiguration.
HeartbeatConnectionChecker - Class in org.axonframework.axonserver.connector.heartbeat.connection.checker: Deprecated.
in through use of the AxonServer java connector
HeartbeatConnectionChecker(long, Consumer<Runnable>, ConnectionSanityChecker, Clock) - Constructor for class org.axonframework.axonserver.connector.heartbeat.connection.checker.HeartbeatConnectionChecker: Deprecated.

Primary constructor of HeartbeatConnectionChecker.
HeartbeatConnectionChecker(Consumer<Runnable>, ConnectionSanityChecker) - Constructor for class org.axonframework.axonserver.connector.heartbeat.connection.checker.HeartbeatConnectionChecker: Deprecated.

Constructs an instance of HeartbeatConnectionChecker using a default timeout of 5 seconds and the system clock.
HeartbeatConnectionChecker(AxonServerConnectionManager, String) - Constructor for class org.axonframework.axonserver.connector.heartbeat.connection.checker.HeartbeatConnectionChecker: Deprecated.

Constructs an instance of HeartbeatConnectionChecker using the specified parameters.
HeartbeatMonitor - Class in org.axonframework.axonserver.connector.heartbeat: Deprecated.
in through use of the AxonServer java connector
HeartbeatMonitor(Runnable, ConnectionSanityChecker, Scheduler, long, long) - Constructor for class org.axonframework.axonserver.connector.heartbeat.HeartbeatMonitor: Deprecated.

Primary constructor of HeartbeatMonitor.
HeartbeatSource - Interface in org.axonframework.axonserver.connector.heartbeat: Deprecated.
in through use of the AxonServer java connector

I

identity() - Static method in interface org.axonframework.axonserver.connector.ManagedChannelCustomizer: Returns a no-op ManagedChannelCustomizer.
INDEX_READ_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
INDEX_WRITE_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
infoSupplier(EventProcessor) - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService: Constructs an EventProcessorInfo for the given processor.
initialize(Configuration) - Method in class org.axonframework.axonserver.connector.event.axon.EventProcessorInfoConfiguration
initialize(Configuration) - Method in class org.axonframework.axonserver.connector.heartbeat.HeartbeatConfiguration: Deprecated.

Initializes the GrpcHeartbeatSource component, needed to send heartbeats to AxonServer, any time the client will receive an heartbeat from the server.
initialResult() - Method in class org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult
initialResult() - Method in class org.axonframework.axonserver.connector.query.subscription.DeserializedResult: Deprecated.
initialResult() - Method in class org.axonframework.axonserver.connector.query.subscription.DisposableResult: Deprecated.
INSTRUCTION_ACK_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
INSTRUCTION_EXECUTION_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
instructionAckSource(InstructionAckSource<QueryProviderOutbound>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Deprecated.
in through use of the AxonServer java connector
InstructionAckSource<T> - Interface in org.axonframework.axonserver.connector: Responsible for sending instruction acknowledgements.
InstructionResultPublisher - Interface in org.axonframework.axonserver.connector: Deprecated.
in through use of the AxonServer java connector
intercept(T) - Method in class org.axonframework.axonserver.connector.DispatchInterceptors
interceptCall(MethodDescriptor<REQ, RESP>, CallOptions, Channel) - Method in class org.axonframework.axonserver.connector.util.GrpcMessageSizeInterceptor
interceptCall(MethodDescriptor<ReqT, RespT>, CallOptions, Channel) - Method in class org.axonframework.axonserver.connector.util.ContextAddingInterceptor: Deprecated.
interceptCall(MethodDescriptor<ReqT, RespT>, CallOptions, Channel) - Method in class org.axonframework.axonserver.connector.util.GrpcBufferingInterceptor: Deprecated.
interceptCall(MethodDescriptor<ReqT, RespT>, CallOptions, Channel) - Method in class org.axonframework.axonserver.connector.util.TokenAddingInterceptor: Deprecated.
INVALID_EVENT_SEQUENCE - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
invokeAll(Collection<? extends Callable<T>>) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
invokeAny(Collection<? extends Callable<T>>) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
isAutomaticBalancing() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling.ProcessorSettings: Returns whether automatic load balancing is configured, yes or no.
isAutoPersistentStreamsEnable() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration
isConnected(String) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Returns true if a gRPC channel for the specific context is opened between client and AxonServer.
isDisableEventBlacklisting() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
In favor of AxonServerConfiguration.setEventBlockListingEnabled(boolean).
isEnabled() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.EventStoreConfiguration: An indicator whether (automatic) configuration of the Axon Server Event Store is enabled.
isEnabled() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration: Indication whether heartbeat messages between a client and Axon Server are enabled.
isEnabled() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Whether (automatic) configuration of the Axon Server Connector is enabled.
isEventBlockListingEnabled() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Flag that allows block-listing of event types to be enabled.
isExceptional() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
isForceReadFromLeader() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Indicates whether it is OK to query events from the local Axon Server node - the node the client is currently connected to.
isForceReconnectThroughServers() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Indicates whether the AxonServerConnectionManager should always reconnect through the servers or try to reconnect with the server it just lost the connection with.
isShortcutQueriesToLocalHandlers() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration
isShutdown() - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
isSnapshot() - Method in class org.axonframework.axonserver.connector.event.axon.GrpcBackedDomainEventData
isSslEnabled() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: A toggle dictating whether to use TLS for the connection to Axon Server
isTerminated() - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
isValid() - Method in class org.axonframework.axonserver.connector.heartbeat.connection.checker.ActiveGrpcChannelChecker: Deprecated.

Returns true if the connection is still alive, false otherwise.
isValid() - Method in class org.axonframework.axonserver.connector.heartbeat.connection.checker.HeartbeatConnectionChecker: Deprecated.

Returns true if the connection is still alive, false otherwise.
isValid() - Method in interface org.axonframework.axonserver.connector.heartbeat.ConnectionSanityChecker: Deprecated.

Returns true if the connection is still alive, false otherwise.

L

loadFactor() - Method in class org.axonframework.axonserver.connector.TopologyChange.HandlerSubscription: Returns the load factor of the HandlerSubscription.
loadFactorProvider(CommandLoadFactorProvider) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the CommandLoadFactorProvider which provides the load factor values for all commands this client can handle.
localSegment() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
localSegment() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
localSegment(CommandBus) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the local CommandBus used to dispatch incoming commands to the local environment.
localSegment(QueryBus) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the local QueryBus used to dispatch incoming queries to the local environment.

M

ManagedChannelCustomizer - Interface in org.axonframework.axonserver.connector: Customizer to add more customizations to a managed channel to Axon Server.
markConsumed(Integer) - Method in class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.

Notifies the stream observer that [@code consumed} messages are processed by the client.
maxMessageSize(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
mergeSegment(int) - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler
messageMonitor(MessageMonitor<? super EventMessage<?>>) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder
messageMonitor(MessageMonitor<? super EventMessage<?>>) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the MessageMonitor to monitor ingested EventMessages.
messageSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the message Serializer used to de-/serialize incoming and outgoing queries and query responses.
META_DATA_SEQUENCING_POLICY - Static variable in class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider: A String constant representing the "meta-data" sequencing policy.

N

name() - Method in class org.axonframework.axonserver.connector.TopologyChange.HandlerSubscription: Returns the name of the HandlerSubscription.
next() - Method in interface org.axonframework.axonserver.connector.event.axon.QueryResultStream: Returns the following QueryResult from this stream.
next() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResultStreamAdapter
nextAvailable() - Method in class org.axonframework.axonserver.connector.event.axon.EventBuffer
NO_EVENT_STORE_MASTER_AVAILABLE - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
NO_HANDLER_FOR_COMMAND - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
NO_HANDLER_FOR_QUERY - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
noOp() - Static method in interface org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.AxonServerEventStoreConfiguration: A AxonServerEventStoreFactory.AxonServerEventStoreConfiguration which does not add any configuration.
noOp() - Static method in interface org.axonframework.axonserver.connector.TargetContextResolver: Returns a no-op TargetContextResolver.
numberOfResults(List<ProcessingInstruction>) - Static method in class org.axonframework.axonserver.connector.util.ProcessingInstructionHelper: Retrieve the desired 'number of results' as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.NR_OF_RESULTS.

O

onChange(TopologyChange) - Method in interface org.axonframework.axonserver.connector.TopologyChangeListener: A handler towards a TopologyChange from the context this listener was registered to.
onCompleted() - Method in class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.
onCompleted() - Method in class org.axonframework.axonserver.connector.util.ResubscribableStreamObserver: Deprecated.
onError(Throwable) - Method in class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.
onError(Throwable) - Method in class org.axonframework.axonserver.connector.util.ResubscribableStreamObserver: Deprecated.
onNext(T) - Method in class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.
onNext(V) - Method in class org.axonframework.axonserver.connector.util.ResubscribableStreamObserver: Deprecated.
open(Consumer<List<? extends EventMessage<?>>>) - Method in class org.axonframework.axonserver.connector.event.axon.PersistentStreamConnection: Initiates the connection to Axon Server to read events from the persistent stream.
openStream(TrackingToken) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore
optionalExceptionResult() - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
order() - Method in class org.axonframework.axonserver.connector.ServerConnectorConfigurerModule
orElse(TargetContextResolver<? super T>) - Method in interface org.axonframework.axonserver.connector.TargetContextResolver: Returns a TargetContextResolver that uses this instance to resolve a context for a given message and if it returns null, returns the results of the other resolver instead.
org.axonframework.axonserver.connector - package org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.command - package org.axonframework.axonserver.connector.command
org.axonframework.axonserver.connector.event.axon - package org.axonframework.axonserver.connector.event.axon
org.axonframework.axonserver.connector.event.util - package org.axonframework.axonserver.connector.event.util
org.axonframework.axonserver.connector.heartbeat - package org.axonframework.axonserver.connector.heartbeat
org.axonframework.axonserver.connector.heartbeat.connection.checker - package org.axonframework.axonserver.connector.heartbeat.connection.checker
org.axonframework.axonserver.connector.heartbeat.source - package org.axonframework.axonserver.connector.heartbeat.source
org.axonframework.axonserver.connector.processor - package org.axonframework.axonserver.connector.processor
org.axonframework.axonserver.connector.query - package org.axonframework.axonserver.connector.query
org.axonframework.axonserver.connector.query.subscription - package org.axonframework.axonserver.connector.query.subscription
org.axonframework.axonserver.connector.util - package org.axonframework.axonserver.connector.util
OTHER - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode

P

parse(Throwable) - Static method in class org.axonframework.axonserver.connector.event.util.GrpcExceptionParser: Convert the give exception into a RuntimeException.
pauseProcessor() - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler
peek() - Method in class org.axonframework.axonserver.connector.event.axon.EventBuffer
PersistentStreamConnection - Class in org.axonframework.axonserver.connector.event.axon: A connection instance receiving the events for a persistent stream to pass on in batches of events to an event consumer.
PersistentStreamConnection(String, Configuration, PersistentStreamProperties, ScheduledExecutorService, int) - Constructor for class org.axonframework.axonserver.connector.event.axon.PersistentStreamConnection: Instantiates a connection for a persistent stream.
PersistentStreamConnection(String, Configuration, PersistentStreamProperties, ScheduledExecutorService, int, String) - Constructor for class org.axonframework.axonserver.connector.event.axon.PersistentStreamConnection: Instantiates a connection for a persistent stream.
PersistentStreamMessageSource - Class in org.axonframework.axonserver.connector.event.axon: A SubscribableMessageSource that receives event from a persistent stream from Axon Server.
PersistentStreamMessageSource(String, Configuration, PersistentStreamProperties, ScheduledExecutorService, int) - Constructor for class org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSource: Instantiates a PersistentStreamMessageSource.
PersistentStreamMessageSource(String, Configuration, PersistentStreamProperties, ScheduledExecutorService, int, String) - Constructor for class org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSource: Instantiates a PersistentStreamMessageSource.
PersistentStreamMessageSourceDefinition - Class in org.axonframework.axonserver.connector.event.axon: Definition of a PersistentStreamMessageSource.
PersistentStreamMessageSourceDefinition(String, PersistentStreamProperties, ScheduledExecutorService, int, String, PersistentStreamMessageSourceFactory) - Constructor for class org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSourceDefinition: Instantiates a PersistentStreamMessageSourceDefinition instance based on the given parameters.
PersistentStreamMessageSourceFactory - Interface in org.axonframework.axonserver.connector.event.axon: Functional interface for creating instances of a PersistentStreamMessageSource.
PersistentStreamScheduledExecutorBuilder - Interface in org.axonframework.axonserver.connector.event.axon: Functional interface towards constructing a ScheduledExecutorService for a PersistentStreamMessageSource.
PersistentStreamSequencingPolicyProvider - Class in org.axonframework.axonserver.connector.event.axon: A provider of SequencingPolicies for a given Configuration.
PersistentStreamSequencingPolicyProvider(String, String, List<String>) - Constructor for class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider: Instantiates a PersistentStreamSequencingPolicyProvider based on the given parameters.
PersistentStreamSettings() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings
platformConnectionManager(AxonServerConnectionManager) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the AxonServerConnectionManager managing the connections to the AxonServer platform.
priority() - Method in class org.axonframework.axonserver.connector.PriorityCallable
priority() - Method in class org.axonframework.axonserver.connector.PriorityRunnable
priority() - Method in interface org.axonframework.axonserver.connector.PriorityTask: Returns the priority of this task.
priority(List<ProcessingInstruction>) - Static method in class org.axonframework.axonserver.connector.util.ProcessingInstructionHelper: Retrieve the priority as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.PRIORITY.
priorityCalculator(CommandPriorityCalculator) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the CommandPriorityCalculator used to deduce the priority of an incoming command among other commands, to give precedence over high(er) valued queries for example.
priorityCalculator(QueryPriorityCalculator) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the QueryPriorityCalculator used to deduce the priority of an incoming query among other queries, to give precedence over high(er) valued queries for example.
PriorityCallable<T> - Class in org.axonframework.axonserver.connector: A wrapper class of Callables that adheres to a priority by implementing PriorityTask.
PriorityCallable(Callable<T>, long, long) - Constructor for class org.axonframework.axonserver.connector.PriorityCallable: Construct a priority task.
PriorityExecutorService - Class in org.axonframework.axonserver.connector.util: This ExecutorService wraps an existing one, creating a PriorityTask for every Runnable that is submitted that's an instance of one.
PriorityRunnable - Class in org.axonframework.axonserver.connector: A wrapper class of Runnables that adheres to a priority by implementing PriorityTask.
PriorityRunnable(Runnable, long, long) - Constructor for class org.axonframework.axonserver.connector.PriorityRunnable: Construct a priority task.
PriorityTask - Interface in org.axonframework.axonserver.connector: Represents a task such as Runnable or Comparable that adheres to a priority by implementing Comparable.
PriorityTaskSchedulers - Interface in org.axonframework.axonserver.connector.util: Responsible for creating Scheduler implementations relevant to the Axon Server connector.
ProcessingInstructionHelper - Class in org.axonframework.axonserver.connector.util: Utility class contain helper methods to extract information from ProcessingInstructions.
processorConfig - Variable in class org.axonframework.axonserver.connector.processor.EventProcessorControlService
ProcessorSettings() - Constructor for class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling.ProcessorSettings
PROPERTY_SEQUENCING_POLICY - Static variable in class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider: A String constant representing the property sequencing policy.
publish(M) - Method in interface org.axonframework.axonserver.connector.Publisher: Deprecated.

Publishes the given message
Publisher<M> - Interface in org.axonframework.axonserver.connector: Deprecated.
in through use of the AxonServer java connector
publishFailureFor(String, String) - Method in interface org.axonframework.axonserver.connector.InstructionResultPublisher: Deprecated.

Notifies to Axon Server a failure during the execution of the specified instruction.
publishFailureFor(String, Throwable) - Method in interface org.axonframework.axonserver.connector.InstructionResultPublisher: Deprecated.

Notifies to Axon Server a failure during the execution of the specified instruction.
publishSuccessFor(String) - Method in interface org.axonframework.axonserver.connector.InstructionResultPublisher: Deprecated.

Notifies to Axon Server a successful execution of the specified instruction.
pulse() - Method in interface org.axonframework.axonserver.connector.heartbeat.HeartbeatSource: Deprecated.

Send an heartbeat to AxonServer
pulse() - Method in class org.axonframework.axonserver.connector.heartbeat.source.GrpcHeartbeatSource: Deprecated.

Send an heartbeat to AxonServer

Q

query(String, boolean) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore
query(QueryMessage<Q, R>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
QUERY_DISPATCH_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
QUERY_EXECUTION_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
QUERY_EXECUTION_NON_TRANSIENT_ERROR - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
QUERY_HANDLER_ADDED - Enum constant in enum class org.axonframework.axonserver.connector.TopologyChange.Type: A change type signalling a query handler was added.
QUERY_HANDLER_REMOVED - Enum constant in enum class org.axonframework.axonserver.connector.TopologyChange.Type: A change type signalling a query handler was removed.
queryExecutorServiceBuilder(ExecutorServiceBuilder) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the ExecutorServiceBuilder which builds an ExecutorService based on a given AxonServerConfiguration and BlockingQueue of Runnable.
queryFlowControl(int, int, int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
queryInProgressAwait(Duration) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the query in progress await timeout used to await the successful termination of queries in progress.
QueryPriorityCalculator - Interface in org.axonframework.axonserver.connector.query: Calculate the priority of QueryMessage based on its content.
queryResponseExecutorServiceBuilder(ExecutorServiceBuilder) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the ExecutorServiceBuilder which builds an ExecutorService based on a given AxonServerConfiguration and BlockingQueue of Runnable.
QueryResult - Class in org.axonframework.axonserver.connector.event.axon: Single result row from a Query to the AxonServer.
QueryResult(EventQueryResultEntry) - Constructor for class org.axonframework.axonserver.connector.event.axon.QueryResult: Constructs a QueryResult from the given entry.
QueryResultStream - Interface in org.axonframework.axonserver.connector.event.axon: Iterator to process the results of a query.
QueryResultStreamAdapter - Class in org.axonframework.axonserver.connector.event.axon: Adapter for the QueryResultStream, wrapping a ResultStream of EventQueryResultEntry.
QueryResultStreamAdapter(ResultStream<EventQueryResultEntry>) - Constructor for class org.axonframework.axonserver.connector.event.axon.QueryResultStreamAdapter: Construct a QueryResultStreamAdapter deferring calls to the given resultStream.
QuerySerializer - Class in org.axonframework.axonserver.connector.query: Converter between Axon Framework QueryMessage and QueryResponseMessage and Axon Server gRPC Query and QueryResponse messages.
QuerySerializer(Serializer, Serializer, AxonServerConfiguration) - Constructor for class org.axonframework.axonserver.connector.query.QuerySerializer: Instantiate a serializer used to convert Axon QueryMessages and QueryResponseMessages into Axon Server gRPC messages and vice versa.
queryUpdateEmitter() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus

R

readEvents(String) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore
register(Case, Handler) - Method in interface org.axonframework.axonserver.connector.Handlers: Registers a handler that can handle instructions for given requestCase regardless of context.
register(Handler) - Method in interface org.axonframework.axonserver.connector.Handlers: Registers a handler that can handle instructions regardless of context or request case.
register(String, Case, Handler) - Method in interface org.axonframework.axonserver.connector.Handlers: Registers a handler that can handle instructions for given context and requestCase.
register(String, Handler) - Method in interface org.axonframework.axonserver.connector.Handlers: Registers a handler that can handle instructions for given context regardless of request case.
register(BiPredicate<String, Case>, Handler) - Method in class org.axonframework.axonserver.connector.DefaultHandlers: Deprecated.
register(BiPredicate<String, Case>, Handler) - Method in interface org.axonframework.axonserver.connector.Handlers: Registers a handler that can handle instructions matching given handlerSelector predicate.
registerDispatchInterceptor(MessageDispatchInterceptor<? super M>) - Method in class org.axonframework.axonserver.connector.DispatchInterceptors
registerDispatchInterceptor(MessageDispatchInterceptor<? super CommandMessage<?>>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?, ?>>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
registerHandlerInterceptor(MessageHandlerInterceptor<? super CommandMessage<?>>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
registerLifecycleHandlers(Lifecycle.LifecycleRegistry) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager
registerLifecycleHandlers(Lifecycle.LifecycleRegistry) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
registerLifecycleHandlers(Lifecycle.LifecycleRegistry) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler
registerLifecycleHandlers(Lifecycle.LifecycleRegistry) - Method in class org.axonframework.axonserver.connector.heartbeat.HeartbeatMonitor: Deprecated.
registerLifecycleHandlers(Lifecycle.LifecycleRegistry) - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService
registerLifecycleHandlers(Lifecycle.LifecycleRegistry) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
releaseSegment(int) - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler
requestStreamFactory(Function<UpstreamAwareStreamObserver<QueryProviderInbound>, StreamObserver<QueryProviderOutbound>>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Deprecated.
in through use of the AxonServer java connector
requestTimeout(long, TimeUnit) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder: Sets the timeout in which a confirmation of the scheduling interaction is expected.
reschedule(ScheduleToken, Duration, Object) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Changes the trigger time for a scheduled event.
RESET - Enum constant in enum class org.axonframework.axonserver.connector.TopologyChange.Type: A change type signalling the connection broke down, willingly or not, resulting in a complete reset.
resolveContext(T) - Method in interface org.axonframework.axonserver.connector.TargetContextResolver: Provides the context to which a message should be routed.
ResubscribableStreamObserver<V> - Class in org.axonframework.axonserver.connector.util: Deprecated.
in through use of the AxonServer java connector
ResubscribableStreamObserver(StreamObserver<V>, Consumer<Throwable>) - Constructor for class org.axonframework.axonserver.connector.util.ResubscribableStreamObserver: Deprecated.

Creates the Re-subscribable Stream Observer.
routingServers() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
In favor of the AxonServerConnectionManager itself being in charge of parsing the AxonServerConfiguration.getServers() list into a NodeInfo collection.
routingServers(String) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Comma separated list of Axon Server locations.
routingStrategy(RoutingStrategy) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the RoutingStrategy used to correctly configure connections between Axon clients and Axon Server.
run() - Method in class org.axonframework.axonserver.connector.PriorityRunnable

S

scatterGather(QueryMessage<Q, R>, long, TimeUnit) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
schedule(Duration, Object) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Schedules an event to be published after a specified amount of time.
schedule(Instant, Object) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Schedules an event to be published at a given moment.
Scheduler - Interface in org.axonframework.axonserver.connector.util: Schedules tasks to be executed in future.
Scheduler.ScheduledTask - Interface in org.axonframework.axonserver.connector.util
scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in interface org.axonframework.axonserver.connector.util.Scheduler: Schedules a command to be executed periodically after initialDelay.
sendAck(String, boolean, ErrorMessage, StreamObserver<T>) - Method in class org.axonframework.axonserver.connector.DefaultInstructionAckSource
sendAck(String, boolean, ErrorMessage, StreamObserver<T>) - Method in interface org.axonframework.axonserver.connector.InstructionAckSource: Sends an acknowledgement.
sendInitialPermits() - Method in class org.axonframework.axonserver.connector.util.FlowControllingStreamObserver: Deprecated.
sendSuccessfulAck(String, StreamObserver<T>) - Method in interface org.axonframework.axonserver.connector.InstructionAckSource: Sends successful acknowledgement.
sendUnsuccessfulAck(String, ErrorMessage, StreamObserver<T>) - Method in interface org.axonframework.axonserver.connector.InstructionAckSource: Sends unsuccessful acknowledgement.
sendUnsupportedInstruction(String, String, StreamObserver<T>) - Method in interface org.axonframework.axonserver.connector.InstructionAckSource: Sends acknowledgement of unsupported instruction.
sequence() - Method in class org.axonframework.axonserver.connector.PriorityCallable
sequence() - Method in class org.axonframework.axonserver.connector.PriorityRunnable
sequence() - Method in interface org.axonframework.axonserver.connector.PriorityTask: Returns the sequence of this task.
SEQUENTIAL_PER_AGGREGATE_POLICY - Static variable in class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider: A String constant representing the "sequential per aggregate" sequencing policy.
SEQUENTIAL_POLICY - Static variable in class org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider: A String constant representing the sequential policy.
serialize(A, Class<T>) - Method in interface org.axonframework.axonserver.connector.util.GrpcObjectSerializer.Serializer: Serialize the given object into an object of the expectedRepresentation.
serialize(Object, Class<T>) - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer
serialize(String, Throwable) - Static method in class org.axonframework.axonserver.connector.util.ExceptionSerializer: Serializes a given Throwable into an ErrorMessage.
serialize(CommandMessage<?>, String, int) - Method in class org.axonframework.axonserver.connector.command.CommandSerializer: Convert a CommandMessage into a Command.
serialize(CommandResultMessage<?>, String) - Method in class org.axonframework.axonserver.connector.command.CommandSerializer: Convert a CommandResultMessage into a CommandProviderOutbound.
serialize(SubscriptionQueryMessage<?, ?, ?>) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Deprecated.
in through use of the AxonServer java connector
serialize(SubscriptionQueryUpdateMessage<?>) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Serializes the given subscriptionQueryUpdateMessage into a QueryUpdate.
serializeQuery(SubscriptionQueryMessage) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Serializes the given subscriptionQueryMessage into a QueryRequest.
serializer(Serializer) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the Serializer used to de-/serialize incoming and outgoing commands and command results.
serializeRequest(QueryMessage<Q, R>, int, long, int) - Method in class org.axonframework.axonserver.connector.query.QuerySerializer: Convert a QueryMessage into a QueryRequest.
serializeRequest(QueryMessage<Q, R>, int, long, int, boolean) - Method in class org.axonframework.axonserver.connector.query.QuerySerializer: Convert a QueryMessage into a QueryRequest.
serializeResponse(QueryResponseMessage<?>, String) - Method in class org.axonframework.axonserver.connector.query.QuerySerializer: Convert a QueryResponseMessage into a QueryResponse.
serializeUpdateType(SubscriptionQueryMessage<?, ?, ?>) - Method in class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Serializes the given subscriptionQueryMessage into a SerializedObject.
ServerConnectorConfigurerModule - Class in org.axonframework.axonserver.connector: Configurer module which is auto-loadable by the DefaultConfigurer that sets sensible default to use when the AxonServer connector is available on the classpath.
ServerConnectorConfigurerModule() - Constructor for class org.axonframework.axonserver.connector.ServerConnectorConfigurerModule
servers(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
setAutomaticBalancing(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling.ProcessorSettings: Sets the automatic load balancing strategy to the given automaticBalancing.
setAutoPersistentStreamsEnable(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration
setAutoPersistentStreamsSettings(AxonServerConfiguration.PersistentStreamSettings) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration
setBatchSize(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the maximum number of events to process in a single transaction when reading a persistent stream.
setCertFile(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the path to the certificate file used for SSL.
setClientId(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the client identifier as it registers itself to Axon Server, must be unique.
setCommandFlowControl(AxonServerConfiguration.FlowControlConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets specific flow control settings for the command message stream.
setCommandLoadFactor(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets an int representing the fixed value of load factor sent to Axon Server for any command's subscription if no specific implementation of CommandLoadFactorProvider is configured.
setCommandThreads(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the number of threads executing commands.
setCommitTimeout(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the timeout (in milliseconds) to wait for response on commit.
setComponentName(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the name of this application.
setConnectionManagementThreadPoolSize(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Define the number of threads that should be used for connection management activities by the AxonServerConnectionFactory used by the AxonServerConnectionManager.
setConnectTimeout(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the value representing the maximum time in milliseconds a request for the initial Axon Server connection may last.
setContext(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the bounded context that this application operates in.
setDisableEventBlacklisting(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
In favor of AxonServerConfiguration.setEventBlockListingEnabled(boolean).
setEnabled(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.EventStoreConfiguration: Sets the indicator whether (automatic) configuration of the Axon Server Event Store is enabled.
setEnabled(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration: Sets the indication whether heartbeat messages between a client and Axon Server are enabled.
setEnabled(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Set whether (automatic) configuration of the Axon Server Connector is enabled.
setEventBlockListingEnabled(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets flag that allows block-listing of event types to be enabled.
setEventFlowControl(AxonServerConfiguration.FlowControlConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets specific flow control settings for the event message stream.
setEventhandling(AxonServerConfiguration.Eventhandling) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Set the AxonServerConfiguration.Eventhandling of this application for Axon Server
setEventSecretKey(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder: Deprecated.
Through use of the Axon Server Java Connector project.
setEventStoreConfiguration(AxonServerConfiguration.EventStoreConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Set the AxonServerConfiguration.EventStoreConfiguration of this application for Axon Server
setFilter(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the expression to filter out events in a persistent stream, expecting the Axon Server Query Language as its syntax.
setForceReadFromLeader(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the indicator whether it is OK to query events from the local Axon Server node - the node the client is currently connected to.
setForceReconnectThroughServers(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the indicator whether the AxonServerConnectionManager should always reconnect through the servers or try to reconnect with the server it just lost the connection with.
setHeartbeat(AxonServerConfiguration.HeartbeatConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the configuration specifics on sending heartbeat messages to ensure a fully operational end-to-end connection with Axon Server.
setInitialNrOfPermits(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Deprecated.
In favor of AxonServerConfiguration.FlowControlConfiguration.setPermits(Integer).
setInitialNrOfPermits(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
In favor of AxonServerConfiguration.setPermits(Integer)
setInitialPosition(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the initial token for the persistent stream.
setInitialSegmentCount(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the number of segments for the persistent stream if it needs to be created.
setInterval(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration: Sets the interval between consecutive heartbeat message sent in milliseconds.
setKeepAliveTime(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the interval (in ms) for keep alive requests, 0 is keep-alive disabled.
setKeepAliveTimeout(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the timeout (in ms) for keep alive requests.
setLoadBalancingStrategy(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Eventhandling.ProcessorSettings: Sets the load balancing strategy for this event processor.
setMaxGrpcBufferedMessages(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
This property is no longer used through adjustments in the Axon Server Java Connector project.
setMaxMessageSize(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the gRPC max inbound message size.
setMaxMessageSizeWarningThreshold(double) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: The threshold (in percentage of 0-1) of the max message size at which a warning should be logged.
setName(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Assigns a name for the persistent stream.
setNewPermitsThreshold(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Sets the threshold at which the application sends new permits to server.
setNewPermitsThreshold(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the threshold at which the application sends new permits to server.
setNrOfNewPermits(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Sets the additional number of permits send for message streams (events, commands, queries) when application is ready for more messages.
setNrOfNewPermits(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the additional number of permits send for message streams (events, commands, queries) when application is ready for more messages.
setOnAvailableCallback(Runnable) - Method in class org.axonframework.axonserver.connector.event.axon.EventBuffer
setPermits(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration: Sets the initial number of permits send for message streams (events, commands, queries).
setPermits(Integer) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the initial number of permits send for message streams (events, commands, queries).
setProcessorsNotificationInitialDelay(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the initial delay (in ms.) before application sends first status update on event processors to Axon Server.
setProcessorsNotificationRate(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the interval (in ms.) application sends status updates on event processors to Axon Server.
setQueryFlowControl(AxonServerConfiguration.FlowControlConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets specific flow control settings for the query message stream.
setQueryResponseThreads(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the number of threads executing query responses.
setQueryThreads(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the number of threads executing queries.
setReconnectInterval(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the amount of time in milliseconds to wait in between attempts to connect to Axon Server.
setSequencingPolicy(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the sequencing policy to use for the persistent stream.
setSequencingPolicyParameters(List<String>) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the parameters specified for the sequencing policy.
setServers(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Set the comma separated list of Axon Server servers.
setShortcutQueriesToLocalHandlers(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration
setSnapshotPrefetch(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the maximum number of Aggregate snapshots which will be retrieved.
setSslEnabled(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Defines whether to use TLS for the connection to Axon Server.
setSuppressDownloadMessage(boolean) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Deprecated.
Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.
setThreadCount(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.PersistentStreamSettings: Sets the number of threads used to process tasks (e.g. event handling) for the persistent stream.
setTimeout(long) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.HeartbeatConfiguration: Sets the time window within which a response is expected in milliseconds.
setToken(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration: Sets the token providing access control with Axon Server.
shutdown() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Stops the Connection Manager, closing any active connections and preventing new connections from being created.
shutdown() - Method in class org.axonframework.axonserver.connector.heartbeat.HeartbeatMonitor: Deprecated.

Stops the scheduled task and shutdown the monitor, that cannot be restarted again.
shutdown() - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
shutdownDispatching() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus: Shutdown the command bus asynchronously for dispatching commands to Axon Server.
shutdownDispatching() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Shuts down the Axon Server EventScheduler implementation.
shutdownDispatching() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus: Shutdown the query bus asynchronously for dispatching queries to Axon Server.
shutdownNow() - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
shutdownNow() - Method in interface org.axonframework.axonserver.connector.util.Scheduler: Cancels all scheduled tasks.
skipMessagesWithPayloadTypeOf(TrackedEventMessage<?>) - Method in class org.axonframework.axonserver.connector.event.axon.EventBuffer
snapshotFilter(Predicate<? super DomainEventData<?>>) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Deprecated.
in favor of AxonServerEventStore.Builder.snapshotFilter(SnapshotFilter)
snapshotFilter(SnapshotFilter) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the SnapshotFilter used to filter snapshots when returning aggregate events.
snapshotFilter(SnapshotFilter) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the SnapshotFilter used to filter snapshots when returning aggregate events.
snapshotPrefetch(int) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
snapshotSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the Serializer used to serialize and deserialize snapshots.
snapshotSerializer(Serializer) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the Serializer used to serialize and deserialize snapshots.
source() - Method in exception org.axonframework.axonserver.connector.AxonServerException
source() - Method in exception org.axonframework.axonserver.connector.query.AxonServerQueryDispatchException: Return a String defining the source where the error originated.
spanFactory(CommandBusSpanFactory) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the CommandBusSpanFactory implementation to use for providing tracing capabilities.
spanFactory(EventBusSpanFactory) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder
spanFactory(EventBusSpanFactory) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the EventBusSpanFactory implementation used for providing tracing capabilities.
spanFactory(QueryBusSpanFactory) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the QueryBusSpanFactory implementation to use for providing tracing capabilities.
spanFactory(SpanFactory) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Deprecated.
Use AxonServerCommandBus.Builder.spanFactory(CommandBusSpanFactory) instead as it provides more configurability.
spanFactory(SpanFactory) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder
spanFactory(SpanFactory) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Deprecated.
Use AxonServerQueryBus.Builder.spanFactory(QueryBusSpanFactory) instead as it provides more configurability.
splitSegment(int) - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler
ssl(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
start() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager: Starts the AxonServerConnectionManager.
start() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus: Start the Axon Server CommandBus implementation.
start() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler: Start the Axon Server EventScheduler implementation.
start() - Method in class org.axonframework.axonserver.connector.heartbeat.HeartbeatMonitor: Deprecated.

Schedule a task that verifies that the connection is still alive and, if it is not, invoke a callback in order to react to the disconnection.
start() - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService: Registers EventProcessor instruction handlers to the ControlChannel for the configured context and set the load balancing strategies through the AdminChannel for the configured context.
start() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus: Start the Axon Server QueryBus implementation.
startProcessor() - Method in class org.axonframework.axonserver.connector.processor.EventProcessorControlService.AxonProcessorInstructionHandler
storageEngine() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore
storageEngine(EventStorageEngine) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder
StreamingEventProcessorInfoMessage - Class in org.axonframework.axonserver.connector.processor: Supplier of PlatformInboundInstruction that represent the status of a StreamingEventProcessor.
streamingQuery(StreamingQueryMessage<Q, R>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
submit(Runnable) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
submit(Runnable, T) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
submit(Callable<T>) - Method in class org.axonframework.axonserver.connector.util.PriorityExecutorService
subscribe(String, Type, MessageHandler<? super QueryMessage<?, R>>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
subscribe(String, MessageHandler<? super CommandMessage<?>>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus
subscribe(Consumer<List<? extends EventMessage<?>>>) - Method in class org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSource
SubscriptionMessageSerializer - Class in org.axonframework.axonserver.connector.query.subscription: Converter between Axon Framework SubscriptionQueryMessage, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage's and Axon Server gRPC SubscriptionQuery and SubscriptionQueryResponse.
SubscriptionMessageSerializer(Serializer, Serializer, AxonServerConfiguration) - Constructor for class org.axonframework.axonserver.connector.query.subscription.SubscriptionMessageSerializer: Instantiate a serializer used to convert Axon SubscriptionQueryMessages, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessages into Axon Server gRPC messages and vice versa.
subscriptionQuery(SubscriptionQueryMessage<Q, I, U>, int) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus
subscriptionQuery(SubscriptionQueryMessage<Q, I, U>, SubscriptionQueryBackpressure, int) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus: Deprecated.
in favor of using the {AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)}
suppressDownloadMessage() - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder: Deprecated.
Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.

T

tagsConfiguration(TagsConfiguration) - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Sets the TagsConfiguration used to add the tags of this Axon instance as client information when setting up a channel.
targetContextResolver(TargetContextResolver<? super CommandMessage<?>>) - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Sets the TargetContextResolver used to resolve the target (bounded) context of an ingested CommandMessage.
targetContextResolver(TargetContextResolver<? super QueryMessage<?, ?>>) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the TargetContextResolver used to resolve the target (bounded) context of an ingested QueryMessage.
TargetContextResolver<T extends org.axonframework.messaging.Message<?>> - Interface in org.axonframework.axonserver.connector: Interface towards a mechanism that is capable of resolving the context name to which a Message should be routed.
timeout(List<ProcessingInstruction>) - Static method in class org.axonframework.axonserver.connector.util.ProcessingInstructionHelper: Retrieve the desired 'number of results' as a long from the given processingInstructions, by searching for the ProcessingInstruction who's key equals the ProcessingKey.NR_OF_RESULTS.
token(String) - Method in class org.axonframework.axonserver.connector.AxonServerConfiguration.Builder
TokenAddingInterceptor - Class in org.axonframework.axonserver.connector.util: Deprecated.
in through use of the AxonServer java connector
TokenAddingInterceptor(String) - Constructor for class org.axonframework.axonserver.connector.util.TokenAddingInterceptor: Deprecated.

Constructs a TokenAddingInterceptor to attach the given token.
TopologyChange - Class in org.axonframework.axonserver.connector: Object representing a topology change at Axon Server.
TopologyChange(TopologyChange) - Constructor for class org.axonframework.axonserver.connector.TopologyChange: Constructs a TopologyChange based on the given gRPC change.
TopologyChange(TopologyChange.Type, String, String, String, String, TopologyChange.HandlerSubscription) - Constructor for class org.axonframework.axonserver.connector.TopologyChange: Constructs a TopologyChange based on the give type, context, clientId, clientStreamId, componentName, and handler.
TopologyChange.HandlerSubscription - Class in org.axonframework.axonserver.connector: The handler subscription of a TopologyChange.
TopologyChange.Type - Enum Class in org.axonframework.axonserver.connector: The enumeration referencing the possible TopologyChange types.
TopologyChangeListener - Interface in org.axonframework.axonserver.connector: A functional interface representing a listener that is notified when a TopologyChange occurs to a specific context.
toString() - Method in exception org.axonframework.axonserver.connector.command.AxonServerCommandDispatchException
toString() - Method in exception org.axonframework.axonserver.connector.command.AxonServerNonTransientRemoteCommandHandlingException
toString() - Method in exception org.axonframework.axonserver.connector.command.AxonServerRemoteCommandHandlingException
toString() - Method in class org.axonframework.axonserver.connector.event.axon.QueryResult
toString() - Method in class org.axonframework.axonserver.connector.PriorityCallable
toString() - Method in class org.axonframework.axonserver.connector.PriorityRunnable
toString() - Method in exception org.axonframework.axonserver.connector.query.AxonServerNonTransientRemoteQueryHandlingException
toString() - Method in exception org.axonframework.axonserver.connector.query.AxonServerRemoteQueryHandlingException
toString() - Method in class org.axonframework.axonserver.connector.TopologyChange.HandlerSubscription
toString() - Method in class org.axonframework.axonserver.connector.TopologyChange
TRANSACTION_ROLLED_BACK - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
type() - Method in class org.axonframework.axonserver.connector.TopologyChange: Returns the Type of the TopologyChange.
typeForClass(Class) - Method in class org.axonframework.axonserver.connector.event.axon.GrpcMetaDataAwareSerializer

U

UNSUPPORTED_INSTRUCTION - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
upcasterChain(EventUpcaster) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Sets the EventUpcaster used to deserialize events of older revisions.
upcasterChain(EventUpcaster) - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Sets the upcaster ch ain used to deserialize events of older revisions.
updateEmitter(QueryUpdateEmitter) - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Sets the QueryUpdateEmitter which can be used to emit updates to queries.
updates() - Method in class org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult
updates() - Method in class org.axonframework.axonserver.connector.query.subscription.DeserializedResult: Deprecated.
updates() - Method in class org.axonframework.axonserver.connector.query.subscription.DisposableResult: Deprecated.
UpstreamAwareStreamObserver<ResT> - Class in org.axonframework.axonserver.connector.util: Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.
UpstreamAwareStreamObserver() - Constructor for class org.axonframework.axonserver.connector.util.UpstreamAwareStreamObserver

V

validate() - Method in class org.axonframework.axonserver.connector.AxonServerConnectionManager.Builder: Validates whether the fields contained in this Builder are set accordingly.
validate() - Method in class org.axonframework.axonserver.connector.command.AxonServerCommandBus.Builder: Validates whether the fields contained in this Builder are set accordingly.
validate() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventScheduler.Builder
validate() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.Builder: Validates whether the fields contained in this Builder are set accordingly.
validate() - Method in class org.axonframework.axonserver.connector.event.axon.AxonServerEventStoreFactory.Builder: Validates whether the fields contained in this Builder are set accordingly.
validate() - Method in class org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder: Validates whether the fields contained in this Builder are set accordingly.
VALIDATION_FAILED - Enum constant in enum class org.axonframework.axonserver.connector.ErrorCode
valueOf(String) - Static method in enum class org.axonframework.axonserver.connector.ErrorCode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.axonframework.axonserver.connector.TopologyChange.Type: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.axonframework.axonserver.connector.ErrorCode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.axonframework.axonserver.connector.TopologyChange.Type: Returns an array containing the constants of this enum class, in the order they are declared.

W

withMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.command.GrpcBackedCommandMessage
withMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.query.GrpcBackedQueryMessage
withMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.query.GrpcBackedResponseMessage
withMetaData(Map<String, ?>) - Method in class org.axonframework.axonserver.connector.query.subscription.GrpcBackedSubscriptionQueryMessage

A B C D E F G H I L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form