All Classes and Interfaces

Class
Description
Deprecated.
in through use of the AxonServer java connector
Axon CommandBus implementation that connects to Axon Server to submit and receive commands and command responses.
Builder class to instantiate an AxonServerCommandBus.
Exception thrown if there is a problem dispatching a command on Axon Server.
Configuration class provided configurable fields and defaults for anything Axon Server related.
 
 
 
 
Configuration class for Flow Control of specific message types.
 
 
The component which manages all the connections which an Axon client can establish with an Axon Server instance.
Builder class to instantiate an AxonServerConnectionManager.
Implementation of the EventScheduler that uses Axon Server to schedule the events.
Builder class to instantiate an AxonServerEventScheduler.
Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.
Builder class to instantiate a AxonServerEventStore.
A factory towards AxonServerEventStores.
Contract defining AxonServerEventStore.Builder based configuration when constructing an AxonServerEventStore.
Builder class to instantiate an AxonServerEventStoreFactory.
Generic exception indicating an error related to AxonServer.
Exception indicating a non-transient problem that was reported by the remote end of a connection.
Exception indicating a non-transient problem that was reported during query handling by the remote end of a connection.
Axon QueryBus implementation that connects to Axon Server to submit and receive queries and query responses.
Builder class to instantiate an AxonServerQueryBus.
An AxonServer Exception which is thrown on a Query Dispatching exception.
Wrapper around standard Axon Framework Registration.
Exception indicating a problem that was reported by the remote end of a connection.
An AxonServer Exception which is thrown on a Query Handling exception.
A SubscriptionQueryResult that emits initial response and update when subscription query response message is received.
Provides the load factor value of the client for the specific command.
Calculate the priority of CommandMessage based on its content.
Converter between Axon Framework CommandMessages and Axon Server gRPC Command messages.
Interface describing functionality for connection managers.
Deprecated.
in through use of the AxonServer java connector
Deprecated.
in through use of the AxonServer java connector
Deprecated.
in through use of the AxonServer java connector
Default implementation of InstructionAckSource.
Default implementation of the PersistentStreamMessageSourceFactory that creates PersistentStreamMessageSource instances.
Deprecated.
in through use of the AxonServer java connector
DispatchInterceptors<M extends org.axonframework.messaging.Message<?>>
Composite of MessageDispatchInterceptors that apply all interceptors in the order of registration.
Deprecated.
in through use of the AxonServer java connector
Converts an Axon Server Error to the relevant Axon framework exception.
Client-side buffer of messages received from the server.
Deprecated.
in through use of the AxonServer java connector
Service that listens to PlatformOutboundInstructions to control EventProcessors when for example requested by Axon Server.
 
Module Configuration implementation that defines the components needed to control and monitor the EventProcessors with AxonServer.
Deprecated.
in through use of the AxonServer java connector
Utility class used to serializer Throwables into ErrorMessages.
A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.
Deprecated.
in through use of the AxonServer java connector
Wrapper that allows clients to access a gRPC Command as a CommandMessage.
DomainEventData implementation that retrieves its raw data from a protobuf Event message.
Wrapper that allows clients to access a gRPC QueryRequest as a QueryMessage.
Wrapper that allows clients to access a gRPC QueryResponse as a QueryResponseMessage.
Wrapper that allows clients to access a gRPC SubscriptionQuery message as a SubscriptionQueryMessage.
Deprecated.
in through use of the AxonServer java connector
Converts GRPC Exceptions to RuntimeExceptions.
Deprecated.
in through use of the AxonServer java connector
Exception thrown when a message exceeds the maximum allowed size.
Interceptor around a gRPC request that checks whether the message size is within the limits of the server.
Exception created to log a warning when a message size exceeds a certain threshold.
Implementation that provides access to a Map of gRPC MetaDataValues in the form of MetaData.
Wrapper around standard Axon Framework serializer that can deserialize Metadata from AxonServer events.
Utility class for converting gRPC MetaData entries into a Java Map and vice versa.
Mapping that translates a MetaData into a map of GRPC MetaDataValue.
Mapping that translates an object into a GRPC SerializedObject.
Contract towards serializing an object of type A.
Mapping that translates a Message into a GRPC SerializedObject.
Wrapper that allows clients to access a gRPC SerializedObject message as a SerializedObject.
Handler registry - gives possibility of registering handlers for specific cases and contexts.
Deprecated.
in through use of the AxonServer java connector
Deprecated.
in through use of the AxonServer java connector
Deprecated.
in through use of the AxonServer java connector
Deprecated.
in through use of the AxonServer java connector
Responsible for sending instruction acknowledgements.
Deprecated.
in through use of the AxonServer java connector
Customizer to add more customizations to a managed channel to Axon Server.
A connection instance receiving the events for a persistent stream to pass on in batches of events to an event consumer.
A SubscribableMessageSource that receives event from a persistent stream from Axon Server.
Functional interface for creating instances of a PersistentStreamMessageSource.
Functional interface towards constructing a ScheduledExecutorService for a PersistentStreamMessageSource.
A provider of SequencingPolicies for a given Configuration.
A wrapper class of Callables that adheres to a priority by implementing PriorityTask.
This ExecutorService wraps an existing one, creating a PriorityTask for every Runnable that is submitted that's an instance of one.
A wrapper class of Runnables that adheres to a priority by implementing PriorityTask.
Represents a task such as Runnable or Comparable that adheres to a priority by implementing Comparable.
Responsible for creating Scheduler implementations relevant to the Axon Server connector.
Utility class contain helper methods to extract information from ProcessingInstructions.
Deprecated.
in through use of the AxonServer java connector
Calculate the priority of QueryMessage based on its content.
Single result row from a Query to the AxonServer.
Iterator to process the results of a query.
Adapter for the QueryResultStream, wrapping a ResultStream of EventQueryResultEntry.
Converter between Axon Framework QueryMessage and QueryResponseMessage and Axon Server gRPC Query and QueryResponse messages.
Deprecated.
in through use of the AxonServer java connector
Schedules tasks to be executed in future.
 
Configurer module which is auto-loadable by the DefaultConfigurer that sets sensible default to use when the AxonServer connector is available on the classpath.
Supplier of PlatformInboundInstruction that represent the status of a StreamingEventProcessor.
Converter between Axon Framework SubscriptionQueryMessage, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage's and Axon Server gRPC SubscriptionQuery and SubscriptionQueryResponse.
TargetContextResolver<T extends org.axonframework.messaging.Message<?>>
Interface towards a mechanism that is capable of resolving the context name to which a Message should be routed.
Deprecated.
in through use of the AxonServer java connector
Object representing a topology change at Axon Server.
The handler subscription of a TopologyChange.
The enumeration referencing the possible TopologyChange types.
A functional interface representing a listener that is notified when a TopologyChange occurs to a specific context.
Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.