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>
-
Method Summary
Modifier and TypeMethodDescriptionbuild()defaultTimeout(Duration defaultTimeout) errorBackoff(Duration errorBackoff) errorHandler(ErrorHandler<REQ, RESP> errorHandler) maxConcurrency(int maxConcurrency) meter(io.opentelemetry.api.metrics.Meter meter) requestIdExtractor(Function<REQ, String> requestIdExtractor) requestWriter(MessageWriter<REQ> requestWriter) responseIdExtractor(Function<RESP, String> responseIdExtractor) responseReader(MessageReader<RESP> responseReader) tracer(io.opentelemetry.api.trace.Tracer tracer) uncorrelatedHandler(UnhandledMessageHandler<RESP> uncorrelatedHandler) writeBufferSize(int writeBufferSize)
-
Method Details
-
transport
-
writeBufferSize
-
requestWriter
-
responseReader
-
requestIdExtractor
-
responseIdExtractor
-
maxConcurrency
-
errorHandler
-
defaultTimeout
-
errorBackoff
-
meter
-
tracer
-
build
-