Package io.bytestreams.exchange.core
Class SymmetricChannel.Builder<T>
java.lang.Object
io.bytestreams.exchange.core.SymmetricChannel.Builder<T>
- Enclosing class:
SymmetricChannel<T>
Builder for
SymmetricChannel.-
Method Summary
Modifier and TypeMethodDescriptionbuild()defaultTimeout(Duration defaultTimeout) errorBackoff(Duration errorBackoff) errorHandler(ErrorHandler<T, T> errorHandler) idExtractor(Function<T, String> idExtractor) maxConcurrency(int maxConcurrency) meter(io.opentelemetry.api.metrics.Meter meter) reader(MessageReader<T> reader) requestHandler(RequestHandler<T, T> requestHandler) tracer(io.opentelemetry.api.trace.Tracer tracer) writeBufferSize(int writeBufferSize) writer(MessageWriter<T> writer)
-
Method Details
-
transport
-
writeBufferSize
-
writer
-
reader
-
idExtractor
-
maxConcurrency
-
requestHandler
-
errorHandler
-
defaultTimeout
-
errorBackoff
-
meter
-
tracer
-
build
-