Interface SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder
- All Superinterfaces:
org.apache.camel.builder.EndpointProducerBuilder,org.apache.camel.EndpointProducerResolver
- All Known Subinterfaces:
SedaEndpointBuilderFactory.AdvancedSedaEndpointBuilder
- Enclosing interface:
SedaEndpointBuilderFactory
public static interface SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder
extends org.apache.camel.builder.EndpointProducerBuilder
Advanced builder for endpoint producers for the SEDA component.
-
Method Summary
Modifier and TypeMethodDescriptionbasic()blockWhenFull(boolean blockWhenFull) Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted.blockWhenFull(String blockWhenFull) Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted.browseLimit(int browseLimit) Maximum number of messages to keep in memory available for browsing.browseLimit(String browseLimit) Maximum number of messages to keep in memory available for browsing.discardIfNoConsumers(boolean discardIfNoConsumers) Whether the producer should discard the message (do not add the message to the queue), when sending to a queue with no active consumers.discardIfNoConsumers(String discardIfNoConsumers) Whether the producer should discard the message (do not add the message to the queue), when sending to a queue with no active consumers.discardWhenFull(boolean discardWhenFull) Whether a thread that sends messages to a full SEDA queue will be discarded.discardWhenFull(String discardWhenFull) Whether a thread that sends messages to a full SEDA queue will be discarded.failIfNoConsumers(boolean failIfNoConsumers) Whether the producer should fail by throwing an exception, when sending to a queue with no active consumers.failIfNoConsumers(String failIfNoConsumers) Whether the producer should fail by throwing an exception, when sending to a queue with no active consumers.lazyStartProducer(boolean lazyStartProducer) Whether the producer should be started lazy (on the first message).lazyStartProducer(String lazyStartProducer) Whether the producer should be started lazy (on the first message).offerTimeout(long offerTimeout) Offer timeout can be added to the block case when queue is full.offerTimeout(String offerTimeout) Offer timeout can be added to the block case when queue is full.Define the queue instance which will be used by the endpoint.queue(BlockingQueue<org.apache.camel.Exchange> queue) Define the queue instance which will be used by the endpoint.Methods inherited from interface org.apache.camel.builder.EndpointProducerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, getRawUriMethods inherited from interface org.apache.camel.EndpointProducerResolver
resolve, resolve
-
Method Details
-
basic
-
blockWhenFull
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder blockWhenFull(boolean blockWhenFull) Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted. By default, an exception will be thrown stating that the queue is full. By enabling this option, the calling thread will instead block and wait until the message can be accepted. The option is a:booleantype. Default: false Group: producer (advanced)- Parameters:
blockWhenFull- the value to set- Returns:
- the dsl builder
-
blockWhenFull
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder blockWhenFull(String blockWhenFull) Whether a thread that sends messages to a full SEDA queue will block until the queue's capacity is no longer exhausted. By default, an exception will be thrown stating that the queue is full. By enabling this option, the calling thread will instead block and wait until the message can be accepted. The option will be converted to abooleantype. Default: false Group: producer (advanced)- Parameters:
blockWhenFull- the value to set- Returns:
- the dsl builder
-
discardIfNoConsumers
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder discardIfNoConsumers(boolean discardIfNoConsumers) Whether the producer should discard the message (do not add the message to the queue), when sending to a queue with no active consumers. Only one of the options discardIfNoConsumers and failIfNoConsumers can be enabled at the same time. The option is a:booleantype. Default: false Group: producer (advanced)- Parameters:
discardIfNoConsumers- the value to set- Returns:
- the dsl builder
-
discardIfNoConsumers
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder discardIfNoConsumers(String discardIfNoConsumers) Whether the producer should discard the message (do not add the message to the queue), when sending to a queue with no active consumers. Only one of the options discardIfNoConsumers and failIfNoConsumers can be enabled at the same time. The option will be converted to abooleantype. Default: false Group: producer (advanced)- Parameters:
discardIfNoConsumers- the value to set- Returns:
- the dsl builder
-
discardWhenFull
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder discardWhenFull(boolean discardWhenFull) Whether a thread that sends messages to a full SEDA queue will be discarded. By default, an exception will be thrown stating that the queue is full. By enabling this option, the calling thread will give up sending and continue, meaning that the message was not sent to the SEDA queue. The option is a:booleantype. Default: false Group: producer (advanced)- Parameters:
discardWhenFull- the value to set- Returns:
- the dsl builder
-
discardWhenFull
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder discardWhenFull(String discardWhenFull) Whether a thread that sends messages to a full SEDA queue will be discarded. By default, an exception will be thrown stating that the queue is full. By enabling this option, the calling thread will give up sending and continue, meaning that the message was not sent to the SEDA queue. The option will be converted to abooleantype. Default: false Group: producer (advanced)- Parameters:
discardWhenFull- the value to set- Returns:
- the dsl builder
-
failIfNoConsumers
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder failIfNoConsumers(boolean failIfNoConsumers) Whether the producer should fail by throwing an exception, when sending to a queue with no active consumers. Only one of the options discardIfNoConsumers and failIfNoConsumers can be enabled at the same time. The option is a:booleantype. Default: false Group: producer (advanced)- Parameters:
failIfNoConsumers- the value to set- Returns:
- the dsl builder
-
failIfNoConsumers
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder failIfNoConsumers(String failIfNoConsumers) Whether the producer should fail by throwing an exception, when sending to a queue with no active consumers. Only one of the options discardIfNoConsumers and failIfNoConsumers can be enabled at the same time. The option will be converted to abooleantype. Default: false Group: producer (advanced)- Parameters:
failIfNoConsumers- the value to set- Returns:
- the dsl builder
-
lazyStartProducer
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder lazyStartProducer(boolean lazyStartProducer) Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option is a:booleantype. Default: false Group: producer (advanced)- Parameters:
lazyStartProducer- the value to set- Returns:
- the dsl builder
-
lazyStartProducer
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder lazyStartProducer(String lazyStartProducer) Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option will be converted to abooleantype. Default: false Group: producer (advanced)- Parameters:
lazyStartProducer- the value to set- Returns:
- the dsl builder
-
offerTimeout
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder offerTimeout(long offerTimeout) Offer timeout can be added to the block case when queue is full. You can disable timeout by using 0 or a negative value. The option is a:longtype. Group: producer (advanced)- Parameters:
offerTimeout- the value to set- Returns:
- the dsl builder
-
offerTimeout
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder offerTimeout(String offerTimeout) Offer timeout can be added to the block case when queue is full. You can disable timeout by using 0 or a negative value. The option will be converted to alongtype. Group: producer (advanced)- Parameters:
offerTimeout- the value to set- Returns:
- the dsl builder
-
browseLimit
Maximum number of messages to keep in memory available for browsing. Use 0 for unlimited. The option is a:inttype. Default: 100 Group: advanced- Parameters:
browseLimit- the value to set- Returns:
- the dsl builder
-
browseLimit
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder browseLimit(String browseLimit) Maximum number of messages to keep in memory available for browsing. Use 0 for unlimited. The option will be converted to ainttype. Default: 100 Group: advanced- Parameters:
browseLimit- the value to set- Returns:
- the dsl builder
-
queue
default SedaEndpointBuilderFactory.AdvancedSedaEndpointProducerBuilder queue(BlockingQueue<org.apache.camel.Exchange> queue) Define the queue instance which will be used by the endpoint. The option is a:java.util.concurrent.BlockingQueue<org.apache.camel.Exchange>type. Group: advanced- Parameters:
queue- the value to set- Returns:
- the dsl builder
-
queue
Define the queue instance which will be used by the endpoint. The option will be converted to ajava.util.concurrent.BlockingQueue<org.apache.camel.Exchange>type. Group: advanced- Parameters:
queue- the value to set- Returns:
- the dsl builder
-