default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.AdvancedDisruptorVmEndpointProducerBuilder.basic() |
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.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 DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.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 DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.producerType(String producerType) |
Defines the producers allowed on the Disruptor.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.producerType(DisruptorVmEndpointBuilderFactory.DisruptorProducerType producerType) |
Defines the producers allowed on the Disruptor.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.size(int size) |
The maximum capacity of the Disruptors ringbuffer Will be effectively
increased to the nearest power of two.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.size(String size) |
The maximum capacity of the Disruptors ringbuffer Will be effectively
increased to the nearest power of two.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.timeout(long timeout) |
Timeout (in milliseconds) before a producer will stop waiting for an
asynchronous task to complete.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.timeout(String timeout) |
Timeout (in milliseconds) before a producer will stop waiting for an
asynchronous task to complete.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.waitForTaskToComplete(String waitForTaskToComplete) |
Option to specify whether the caller should wait for the async task
to complete or not before continuing.
|
default DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder |
DisruptorVmEndpointBuilderFactory.DisruptorVmEndpointProducerBuilder.waitForTaskToComplete(org.apache.camel.WaitForTaskToComplete waitForTaskToComplete) |
Option to specify whether the caller should wait for the async task
to complete or not before continuing.
|