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.
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.Definition of a
PersistentStreamMessageSource.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.
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.