Package io.bytestreams.exchange.core

Class SymmetricChannel.Builder<T>

java.lang.Object

io.bytestreams.exchange.core.SymmetricChannel.Builder<T>

Enclosing class:

SymmetricChannel<T>

public static final class SymmetricChannel.Builder<T>
extends Object

Builder for SymmetricChannel.

Method Summary

Modifier and Type	Method	Description
SymmetricChannel<T>	build()
SymmetricChannel.Builder<T>	defaultTimeout(Duration defaultTimeout)
SymmetricChannel.Builder<T>	errorBackoff(Duration errorBackoff)
SymmetricChannel.Builder<T>	errorHandler(ErrorHandler<T,T> errorHandler)
SymmetricChannel.Builder<T>	idExtractor(Function<T,String> idExtractor)
SymmetricChannel.Builder<T>	maxConcurrency(int maxConcurrency)
SymmetricChannel.Builder<T>	meter(io.opentelemetry.api.metrics.Meter meter)
SymmetricChannel.Builder<T>	reader(MessageReader<T> reader)
SymmetricChannel.Builder<T>	requestHandler(RequestHandler<T,T> requestHandler)
SymmetricChannel.Builder<T>	tracer(io.opentelemetry.api.trace.Tracer tracer)
SymmetricChannel.Builder<T>	transport(Transport transport)
SymmetricChannel.Builder<T>	writeBufferSize(int writeBufferSize)
SymmetricChannel.Builder<T>	writer(MessageWriter<T> writer)

Methods inherited from class java.lang.Object

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

Method Details

transport

public SymmetricChannel.Builder<T> transport(Transport transport)

writeBufferSize

public SymmetricChannel.Builder<T> writeBufferSize(int writeBufferSize)

writer

public SymmetricChannel.Builder<T> writer(MessageWriter<T> writer)

reader

public SymmetricChannel.Builder<T> reader(MessageReader<T> reader)

idExtractor

public SymmetricChannel.Builder<T> idExtractor(Function<T,String> idExtractor)

maxConcurrency

public SymmetricChannel.Builder<T> maxConcurrency(int maxConcurrency)

requestHandler

public SymmetricChannel.Builder<T> requestHandler(RequestHandler<T,T> requestHandler)

errorHandler

public SymmetricChannel.Builder<T> errorHandler(ErrorHandler<T,T> errorHandler)

defaultTimeout

public SymmetricChannel.Builder<T> defaultTimeout(Duration defaultTimeout)

errorBackoff

public SymmetricChannel.Builder<T> errorBackoff(Duration errorBackoff)

meter

public SymmetricChannel.Builder<T> meter(io.opentelemetry.api.metrics.Meter meter)

tracer

public SymmetricChannel.Builder<T> tracer(io.opentelemetry.api.trace.Tracer tracer)

build

public SymmetricChannel<T> build()