default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.backpressureStrategy(org.apache.camel.component.reactive.streams.ReactiveStreamsBackpressureStrategy backpressureStrategy) |
The backpressure strategy to use when pushing events to a slow
subscriber.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
static ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.reactiveStreams() |
Reactive Streams (camel-reactive-streams)
Exchange messages with reactive stream processing libraries compatible
with the reactive streams standard.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.reactiveStreamsEngineConfiguration(org.apache.camel.component.reactive.streams.engine.ReactiveStreamsEngineConfiguration reactiveStreamsEngineConfiguration) |
To use an existing reactive stream engine configuration.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.serviceType(String serviceType) |
Set the type of the underlying reactive streams implementation to
use.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.threadPoolMaxSize(int threadPoolMaxSize) |
The maximum number of threads used by the reactive streams internal
engine.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.threadPoolMinSize(int threadPoolMinSize) |
The minimum number of threads used by the reactive streams internal
engine.
|
default ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder |
ReactiveStreamsComponentBuilderFactory.ReactiveStreamsComponentBuilder.threadPoolName(String threadPoolName) |
The name of the thread pool used by the reactive streams internal
engine.
|