Package io.bytestreams.exchange.core

package io.bytestreams.exchange.core

Core interfaces and channels for application protocol messaging.

Provides the building blocks for request-response application protocols over any Transport. Three correlation models are supported:

• Lockstep — one in-flight request, positional correlation (pipelined with capacity 1)
• Pipelined — N in-flight requests, strict ordering, positional correlation
• Multiplexed — N in-flight requests, relaxed ordering, explicit ID correlation

Interfaces

• Channel — logical messaging channel
• ClientChannel — client-side channel for sending requests
• Transport — pluggable I/O transport
• ErrorHandler — handles channel errors

Types

• ChannelStatus — channel lifecycle states
• ErrorContext — structured error information
• DuplicateCorrelationIdException — duplicate correlation key

Extension Points

• AbstractChannel — base class for building custom channel implementations with managed I/O loops, OTel instrumentation, and lifecycle

Implementations

• PipelinedChannel — Transport-backed pipelined client channel
• MultiplexedChannel — Transport-backed multiplexed client channel
• SymmetricChannel — bidirectional symmetric channel
• ServerChannel — server-side channel for receiving requests
• SocketTransport — TCP socket transport
• invalid reference

  io.bytestreams.exchange.core.SocketAcceptor

  — server-side TCP connection acceptor

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