default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.AdvancedDisruptorEndpointProducerBuilder.basic() |
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.blockWhenFull(boolean blockWhenFull) |
Whether a thread that sends messages to a full Disruptor will block
until the ringbuffer's capacity is no longer exhausted.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.blockWhenFull(String blockWhenFull) |
Whether a thread that sends messages to a full Disruptor will block
until the ringbuffer's capacity is no longer exhausted.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.producerType(String producerType) |
Defines the producers allowed on the Disruptor.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.producerType(DisruptorEndpointBuilderFactory.DisruptorProducerType producerType) |
Defines the producers allowed on the Disruptor.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.size(int size) |
The maximum capacity of the Disruptors ringbuffer Will be effectively
increased to the nearest power of two.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.size(String size) |
The maximum capacity of the Disruptors ringbuffer Will be effectively
increased to the nearest power of two.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.timeout(long timeout) |
Timeout (in milliseconds) before a producer will stop waiting for an
asynchronous task to complete.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.timeout(String timeout) |
Timeout (in milliseconds) before a producer will stop waiting for an
asynchronous task to complete.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.waitForTaskToComplete(String waitForTaskToComplete) |
Option to specify whether the caller should wait for the async task
to complete or not before continuing.
|
default DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder |
DisruptorEndpointBuilderFactory.DisruptorEndpointProducerBuilder.waitForTaskToComplete(org.apache.camel.WaitForTaskToComplete waitForTaskToComplete) |
Option to specify whether the caller should wait for the async task
to complete or not before continuing.
|