Uses of Package
io.axoniq.axonserver.connector.impl

Packages that use io.axoniq.axonserver.connector.impl

Package	Description
io.axoniq.axonserver.connector
io.axoniq.axonserver.connector.admin.impl
io.axoniq.axonserver.connector.command.impl
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.connector.event.transformation.impl
io.axoniq.axonserver.connector.event.transformation.impl.grpc
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.connector.impl.buffer
io.axoniq.axonserver.connector.query.impl

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector

Class	Description
ServerAddress	Definition of an AxonServer address, defining the ServerAddress.getGrpcPort() and ServerAddress.getHostName().

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.admin.impl

Class	Description
AbstractAxonServerChannel	Abstract class representing a channel with AxonServer.
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.command.impl

Class	Description
AbstractAxonServerChannel	Abstract class representing a channel with AxonServer.
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.event.impl

Class	Description
AbstractAxonServerChannel	Abstract class representing a channel with AxonServer.
AbstractBufferedStream	An abstract FlowControlledBuffer and ResultStream implementation, used to provide a buffered stream of results of T when receiving a request of type R.
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.
FlowControlledBuffer	Abstract implementation of the FlowControlledStream, adding buffering logic to the flow controlled stream.
FlowControlledStream	Abstract implementation of a ClientResponseObserver providing flow control.

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.event.transformation.impl

Class	Description
AbstractAxonServerChannel	Abstract class representing a channel with AxonServer.
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.event.transformation.impl.grpc

Class	Description
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.impl

Class	Description
AbstractAxonServerChannel	Abstract class representing a channel with AxonServer.
AxonConnectorThreadFactory	A ThreadFactory implementation for AxonServer Connector threads.
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.
CloseableBuffer	A buffer that can be closed by the producing side.
CloseableReadonlyBuffer	A readonly buffer that can be closed from the producing side.
ContextConnection	Implementation of the AxonServerConnection, carrying context information with the overall connection.
DisposableReadonlyBuffer	A buffer that can be disposed of from the subscriber's side.
FlowControlledBuffer	Abstract implementation of the FlowControlledStream, adding buffering logic to the flow controlled stream.
FlowControlledStream	Abstract implementation of a ClientResponseObserver providing flow control.
HeartbeatSender	Functional interface defining a method to send heartbeats with.
NoopFlowControl	NOOP implementation of FlowControl.
ObjectUtils.OrElse	Class allowing the invocation of a given Runnable depending on whether the previous operation was executed, formulated as a boolean.
ReconnectConfiguration	Container of configuration variables used when reconnecting to a channel.
ServerAddress	Definition of an AxonServer address, defining the ServerAddress.getGrpcPort() and ServerAddress.getHostName().

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.impl.buffer

Class	Description
CloseableBuffer	A buffer that can be closed by the producing side.
CloseableReadonlyBuffer	A readonly buffer that can be closed from the producing side.
DisposableReadonlyBuffer	A buffer that can be disposed of from the subscriber's side.

Classes in io.axoniq.axonserver.connector.impl used by io.axoniq.axonserver.connector.query.impl

Class	Description
AbstractAxonServerChannel	Abstract class representing a channel with AxonServer.
AbstractBufferedStream	An abstract FlowControlledBuffer and ResultStream implementation, used to provide a buffered stream of results of T when receiving a request of type R.
AxonServerManagedChannel	AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.
FlowControlledBuffer	Abstract implementation of the FlowControlledStream, adding buffering logic to the flow controlled stream.
FlowControlledStream	Abstract implementation of a ClientResponseObserver providing flow control.