Package io.axoniq.framework.axonserver.connector.util

@NullMarked package io.axoniq.framework.axonserver.connector.util

Part of the Axon Server Connector module. Contains classes related to utility.

Class	Description
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.
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.
ProcessingInstructionUtils	Utility class contain helper methods to extract information from ProcessingInstructions.
Scheduler	Schedules tasks to be executed in future.
Scheduler.ScheduledTask
UpstreamAwareStreamObserver<ResT>	Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.