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>
Scheduler	Schedules tasks to be executed in future.
Scheduler.ScheduledTask

Class Summary

Class	Description
AxonFrameworkVersionResolver	Provides Axon Framework current version.
BufferingSpliterator<R>	Converts the push interface for QueryResponses from Axon Server to a pull interface to be used by Axon Framework.
ContextAddingInterceptor	Interceptor around a gRPC request to add a Context element to the metadata.
ExceptionSerializer	Author: marc
FlowControllingStreamObserver<T>	Wrapper around the standard StreamObserver that guarantees that the onNext calls are executed in a thread-safe manner.
GrpcBufferingInterceptor	Interceptor that immediately requests a number of messages from the server, to increase the flow of messages.
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.
ProcessingInstructionHelper	Utility class contain helper methods to extract information from ProcessingInstructions.
ResubscribableStreamObserver<V>	Wrapper around StreamObserver that re-subscribes on error received (if other side is still available).
TokenAddingInterceptor	Interceptor around a GRPC request to add a Token element to the metadata.
UpstreamAwareStreamObserver<ResT>	Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.