An implementation of the Queue components for asynchronous SEDA exchanges on a {@link BlockingQueue} within a CamelContext
Name | Type | Description |
---|---|---|
blockWhenFull | boolean | |
concurrentConsumers | int | |
exchangePattern | org.apache.camel.ExchangePattern | Sets the default exchange pattern to use for {@link #createExchange()}. The default value is {@link ExchangePattern#InOnly} |
failIfNoConsumers | boolean | |
multipleConsumers | boolean | |
pollTimeout | int | |
purgeWhenStopping | boolean | |
size | int | |
synchronous | boolean | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). @param synchronous true to enforce synchronous processing |
timeout | long | |
waitForTaskToComplete | org.apache.camel.WaitForTaskToComplete |
A Consumer for the SEDA component.
In this implementation there is a little slack period when you suspend/stop the consumer, by which the consumer may pickup a newly arrived messages and process it. That period is up till 1 second. @version