Package org.axonframework.axonserver.connector.util
package org.axonframework.axonserver.connector.util
-
ClassDescriptionUtility class used to serializer
Throwables intoErrorMessages.Converts GRPC Exceptions toRuntimeExceptions.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.ThisExecutorServicewraps an existing one, creating aPriorityTaskfor everyRunnablethat is submitted that's an instance of one.Responsible for creatingSchedulerimplementations relevant to the Axon Server connector.Utility class contain helper methods to extract information fromProcessingInstructions.Schedules tasks to be executed in future.Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.