Package io.bytestreams.exchange.core

Class MultiplexedChannel.Builder<REQ,RESP>

java.lang.Object

io.bytestreams.exchange.core.MultiplexedChannel.Builder<REQ,RESP>

Enclosing class:

MultiplexedChannel<REQ,RESP>

public static final class MultiplexedChannel.Builder<REQ,RESP>
extends Object

Method Summary

Modifier and Type	Method	Description
MultiplexedChannel<REQ,RESP>	build()
MultiplexedChannel.Builder<REQ,RESP>	defaultTimeout(Duration defaultTimeout)
MultiplexedChannel.Builder<REQ,RESP>	errorBackoff(Duration errorBackoff)
MultiplexedChannel.Builder<REQ,RESP>	errorHandler(ErrorHandler<REQ,RESP> errorHandler)
MultiplexedChannel.Builder<REQ,RESP>	maxConcurrency(int maxConcurrency)
MultiplexedChannel.Builder<REQ,RESP>	meter(io.opentelemetry.api.metrics.Meter meter)
MultiplexedChannel.Builder<REQ,RESP>	requestIdExtractor(Function<REQ,String> requestIdExtractor)
MultiplexedChannel.Builder<REQ,RESP>	requestWriter(MessageWriter<REQ> requestWriter)
MultiplexedChannel.Builder<REQ,RESP>	responseIdExtractor(Function<RESP,String> responseIdExtractor)
MultiplexedChannel.Builder<REQ,RESP>	responseReader(MessageReader<RESP> responseReader)
MultiplexedChannel.Builder<REQ,RESP>	tracer(io.opentelemetry.api.trace.Tracer tracer)
MultiplexedChannel.Builder<REQ,RESP>	transport(Transport transport)
MultiplexedChannel.Builder<REQ,RESP>	uncorrelatedHandler(UnhandledMessageHandler<RESP> uncorrelatedHandler)
MultiplexedChannel.Builder<REQ,RESP>	writeBufferSize(int writeBufferSize)

Methods inherited from class java.lang.Object

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

Method Details

transport

public MultiplexedChannel.Builder<REQ,RESP> transport(Transport transport)

writeBufferSize

public MultiplexedChannel.Builder<REQ,RESP> writeBufferSize(int writeBufferSize)

requestWriter

public MultiplexedChannel.Builder<REQ,RESP> requestWriter(MessageWriter<REQ> requestWriter)

responseReader

public MultiplexedChannel.Builder<REQ,RESP> responseReader(MessageReader<RESP> responseReader)

requestIdExtractor

public MultiplexedChannel.Builder<REQ,RESP> requestIdExtractor(Function<REQ,String> requestIdExtractor)

responseIdExtractor

public MultiplexedChannel.Builder<REQ,RESP> responseIdExtractor(Function<RESP,String> responseIdExtractor)

maxConcurrency

public MultiplexedChannel.Builder<REQ,RESP> maxConcurrency(int maxConcurrency)

uncorrelatedHandler

public MultiplexedChannel.Builder<REQ,RESP> uncorrelatedHandler(UnhandledMessageHandler<RESP> uncorrelatedHandler)

errorHandler

public MultiplexedChannel.Builder<REQ,RESP> errorHandler(ErrorHandler<REQ,RESP> errorHandler)

defaultTimeout

public MultiplexedChannel.Builder<REQ,RESP> defaultTimeout(Duration defaultTimeout)

errorBackoff

public MultiplexedChannel.Builder<REQ,RESP> errorBackoff(Duration errorBackoff)

meter

public MultiplexedChannel.Builder<REQ,RESP> meter(io.opentelemetry.api.metrics.Meter meter)

tracer

public MultiplexedChannel.Builder<REQ,RESP> tracer(io.opentelemetry.api.trace.Tracer tracer)

build

public MultiplexedChannel<REQ,RESP> build()