Package org.axonframework.axonserver.connector.util

Interface Summary

Interface	Description
ExecutorServiceBuilder	A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.
GrpcObjectSerializer.Serializer<A>	Contract towards serializing an object of type A.
PriorityTaskSchedulers	Responsible for creating Scheduler implementations relevant to the Axon Server connector.
Scheduler	Schedules tasks to be executed in future.
Scheduler.ScheduledTask

Class Summary

Class	Description
ContextAddingInterceptor	Deprecated in through use of the AxonServer java connector
ExceptionSerializer	Utility class used to serializer Throwables into ErrorMessages.
FlowControllingStreamObserver<T>	Deprecated in through use of the AxonServer java connector
GrpcBufferingInterceptor	Deprecated in through use of the AxonServer java connector
GrpcMetaData	Implementation that provides access to a Map of gRPC MetaDataValues in the form of MetaData.
GrpcMetaDataConverter	Utility class for converting gRPC MetaData entries into a Java Map and vice versa.
GrpcMetadataSerializer	Mapping that translates a MetaData into a map of GRPC MetaDataValue.
GrpcObjectSerializer<O>	Mapping that translates an object into a GRPC SerializedObject.
GrpcPayloadSerializer	Mapping that translates a Message into a GRPC SerializedObject.
GrpcSerializedObject	Wrapper that allows clients to access a gRPC SerializedObject message as a SerializedObject.
PriorityExecutorService	This ExecutorService wraps an existing one, creating a PriorityTask for every Runnable that is submitted that's an instance of one.
ProcessingInstructionHelper	Utility class contain helper methods to extract information from ProcessingInstructions.
ResubscribableStreamObserver<V>	Deprecated in through use of the AxonServer java connector
TokenAddingInterceptor	Deprecated in through use of the AxonServer java connector
UpstreamAwareStreamObserver<ResT>	Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.