Package io.bytestreams.exchange.core

Class ResilientTransport

java.lang.Object

io.bytestreams.exchange.core.ResilientTransport

All Implemented Interfaces:

Transport, Closeable, AutoCloseable

public final class ResilientTransport
extends Object
implements Transport

A Transport decorator that automatically reconnects using a TransportFactory when the underlying transport fails.

Reconnection happens at message boundaries — when inputStream() or outputStream() is called after a failure has been detected. The returned streams are wrapped to detect I/O failures and set an internal stale flag, which triggers reconnection on the next stream access.

Stream identity: Unlike the general Transport contract, this implementation may return different stream instances after a reconnect. This is safe with AbstractChannel, which re-fetches streams on each loop iteration.

Use builder(TransportFactory) to configure backoff strategy and max attempts.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ResilientTransport.Builder

Method Summary

Modifier and Type	Method	Description
io.opentelemetry.api.common.Attributes	attributes()	Returns transport-level OTel attributes (e.g. network type, peer address, peer port).
static ResilientTransport.Builder	builder(TransportFactory factory)
void	close()
InputStream	inputStream()	Returns the input stream for reading inbound messages.
OutputStream	outputStream()	Returns the output stream for writing outbound messages.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static ResilientTransport.Builder builder(TransportFactory factory)

inputStream

public InputStream inputStream()
                        throws IOException

Description copied from interface: Transport

Returns the input stream for reading inbound messages.

Specified by:

inputStream in interface Transport

Throws:

IOException

outputStream

public OutputStream outputStream()
                          throws IOException

Description copied from interface: Transport

Returns the output stream for writing outbound messages.

Specified by:

outputStream in interface Transport

Throws:

IOException

attributes

public io.opentelemetry.api.common.Attributes attributes()

Description copied from interface: Transport

Returns transport-level OTel attributes (e.g. network type, peer address, peer port).

Specified by:

attributes in interface Transport

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Transport

Throws:

IOException