Interface ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder

    • Method Detail

      • bridgeErrorHandler

        default 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. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option is a: boolean type. Default: false Group: consumer
      • bridgeErrorHandler

        default 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. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option will be converted to a boolean type. Default: false Group: consumer
      • exchangesRefillLowWatermark

        default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder exchangesRefillLowWatermark​(double exchangesRefillLowWatermark)
        Set the low watermark of requested exchanges to the active subscription as percentage of the maxInflightExchanges. When the number of pending items from the upstream source is lower than the watermark, new items can be requested to the subscription. If set to 0, the subscriber will request items in batches of maxInflightExchanges, only after all items of the previous batch have been processed. If set to 1, the subscriber can request a new item each time an exchange is processed (chatty). Any intermediate value can be used. The option is a: double type. Default: 0.25 Group: consumer
      • exchangesRefillLowWatermark

        default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder exchangesRefillLowWatermark​(String exchangesRefillLowWatermark)
        Set the low watermark of requested exchanges to the active subscription as percentage of the maxInflightExchanges. When the number of pending items from the upstream source is lower than the watermark, new items can be requested to the subscription. If set to 0, the subscriber will request items in batches of maxInflightExchanges, only after all items of the previous batch have been processed. If set to 1, the subscriber can request a new item each time an exchange is processed (chatty). Any intermediate value can be used. The option will be converted to a double type. Default: 0.25 Group: consumer
      • maxInflightExchanges

        default ReactiveStreamsEndpointBuilderFactory.ReactiveStreamsEndpointConsumerBuilder maxInflightExchanges​(String maxInflightExchanges)
        Maximum number of exchanges concurrently being processed by Camel. This parameter controls backpressure on the stream. Setting a non-positive value will disable backpressure. The option will be converted to a java.lang.Integer type. Default: 128 Group: consumer