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.
 
A Channel backed by a Transport that receives requests and dispatches them to a registered handler.
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.