Package org.axonframework.axonserver.connector.util

package org.axonframework.axonserver.connector.util

Related Packages

Package	Description
org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.command
org.axonframework.axonserver.connector.heartbeat
org.axonframework.axonserver.connector.processor
org.axonframework.axonserver.connector.query

Class	Description
ContextAddingInterceptor	Deprecated. in through use of the AxonServer java connector
ExceptionSerializer	Utility class used to serializer Throwables into ErrorMessages.
ExecutorServiceBuilder	A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.
FlowControllingStreamObserver<T>	Deprecated. in through use of the AxonServer java connector
GrpcBufferingInterceptor	Deprecated. in through use of the AxonServer java connector
GrpcMessageSizeExceededException	Exception thrown when a message exceeds the maximum allowed size.
GrpcMessageSizeInterceptor	Interceptor around a gRPC request that checks whether the message size is within the limits of the server.
GrpcMessageSizeWarningThresholdReachedException	Exception created to log a warning when a message size exceeds a certain threshold.
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.
GrpcObjectSerializer.Serializer<A>	Contract towards serializing an object of type A.
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.
PriorityTaskSchedulers	Responsible for creating Scheduler implementations relevant to the Axon Server connector.
ProcessingInstructionHelper	Utility class contain helper methods to extract information from ProcessingInstructions.
ResubscribableStreamObserver<V>	Deprecated. in through use of the AxonServer java connector
Scheduler	Schedules tasks to be executed in future.
Scheduler.ScheduledTask
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.