All Classes and Interfaces
Class
Description
Base class for
Transport-backed channels with managed I/O loops.Accepts transports from a
TransportFactory and creates channels for each.Strategy for computing the delay between retry attempts.
A logical messaging channel between two endpoints.
The lifecycle status of a
Channel.A
Channel that sends requests and receives correlated responses.A
TransportFactory that creates client-side TCP connections.Thrown when a message's correlation id is already pending.
Structured context for a channel error, carrying the cause and any associated request/response.
Handles channel errors.
Reads a message from an input stream.
Writes a message to an output stream.
A
ClientChannel backed by a Transport using ID-based (multiplexed) correlation.OpenTelemetry constants and helpers.
Identifies the traffic direction for a channel, used as an OTel metric attribute.
A
ClientChannel backed by a Transport using positional (pipelined) correlation.Handles an incoming request by completing the given future with a response.
A
Transport decorator that automatically reconnects using a TransportFactory when
the underlying transport fails.Builder for
ServerChannel.A
TransportFactory that accepts incoming TCP connections on a ServerSocket.Configures a
Socket.A
MultiplexedChannel where request and response types are the same (T=T),
enabling bidirectional symmetric messaging on a single connection.Builder for
SymmetricChannel.Pluggable I/O transport that provides input/output streams and connection metadata.
Factory for creating new
Transport instances.Callback for inbound messages that could not be correlated to a pending request in a
MultiplexedChannel.