Uses of Package
org.axonframework.axonserver.connector.util

Packages that use org.axonframework.axonserver.connector.util

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

Classes in org.axonframework.axonserver.connector.util used by org.axonframework.axonserver.connector

Class and Description
UpstreamAwareStreamObserver Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.

Classes in org.axonframework.axonserver.connector.util used by org.axonframework.axonserver.connector.command

Class and Description
ExecutorServiceBuilder A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.
UpstreamAwareStreamObserver Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.

Classes in org.axonframework.axonserver.connector.util used by org.axonframework.axonserver.connector.heartbeat

Class and Description
Scheduler Schedules tasks to be executed in future.

Classes in org.axonframework.axonserver.connector.util used by org.axonframework.axonserver.connector.query

Class and Description
ExecutorServiceBuilder A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.
UpstreamAwareStreamObserver Convenience implementation of a StreamObserver that provides access to the request stream, which allows cancellation of the call, flow control, etc.

Classes in org.axonframework.axonserver.connector.util used by org.axonframework.axonserver.connector.util

Class and Description
ExecutorServiceBuilder A Functional Interface towards a BiFunction which ingests both an AxonServerConfiguration and a BlockingQueue of Runnable, and outputs an ExecutorService.
FlowControllingStreamObserver Wrapper around the standard StreamObserver that guarantees that the onNext calls are executed in a thread-safe manner.
GrpcMetaDataConverter Utility class for converting gRPC MetaData entries into a Java Map and vice versa.
Scheduler.ScheduledTask