default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.AdvancedReactiveStreamsEndpointConsumerBuilder.basic() |
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.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 ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.bridgeErrorHandler(String 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 ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.concurrentConsumers(int concurrentConsumers) |
Number of threads used to process exchanges in the Camel route.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers) |
Number of threads used to process exchanges in the Camel route.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.exchangesRefillLowWatermark(double exchangesRefillLowWatermark) |
Set the low watermark of requested exchanges to the active
subscription as percentage of the maxInflightExchanges.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.exchangesRefillLowWatermark(String exchangesRefillLowWatermark) |
Set the low watermark of requested exchanges to the active
subscription as percentage of the maxInflightExchanges.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.forwardOnComplete(boolean forwardOnComplete) |
Determines if onComplete events should be pushed to the Camel route.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.forwardOnComplete(String forwardOnComplete) |
Determines if onComplete events should be pushed to the Camel route.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.forwardOnError(boolean forwardOnError) |
Determines if onError events should be pushed to the Camel route.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.forwardOnError(String forwardOnError) |
Determines if onError events should be pushed to the Camel route.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.maxInflightExchanges(Integer maxInflightExchanges) |
Maximum number of exchanges concurrently being processed by Camel.
|
default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder |
ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder.maxInflightExchanges(String maxInflightExchanges) |
Maximum number of exchanges concurrently being processed by Camel.
|