ThreadsDefinition |
ThreadsDefinition.allowCoreThreadTimeOut(boolean allowCoreThreadTimeOut) |
Whether idle core threads are allowed to timeout and therefore can shrink the pool size below the core pool size
|
ThreadsDefinition |
ThreadsDefinition.allowCoreThreadTimeOut(String allowCoreThreadTimeOut) |
Whether idle core threads is allowed to timeout and therefore can shrink the pool size below the core pool size
|
ThreadsDefinition |
ThreadsDefinition.callerRunsWhenRejected(boolean callerRunsWhenRejected) |
Whether or not to use as caller runs as fallback when a task is rejected being added to the thread pool
(when its full).
|
ThreadsDefinition |
ThreadsDefinition.callerRunsWhenRejected(String callerRunsWhenRejected) |
Whether or not to use as caller runs as fallback when a task is rejected being added to the thread pool
(when its full).
|
ThreadsDefinition |
ThreadsDefinition.executorService(ExecutorService executorService) |
To use a custom thread pool
|
ThreadsDefinition |
ThreadsDefinition.executorServiceRef(String executorServiceRef) |
To refer to a custom thread pool or use a thread pool profile (as overlay)
|
ThreadsDefinition |
ThreadsDefinition.keepAliveTime(long keepAliveTime) |
Sets the keep alive time for idle threads
|
ThreadsDefinition |
ThreadsDefinition.keepAliveTime(String keepAliveTime) |
Sets the keep alive time for idle threads
|
ThreadsDefinition |
ThreadsDefinition.maxPoolSize(int maxPoolSize) |
Sets the maximum pool size
|
ThreadsDefinition |
ThreadsDefinition.maxPoolSize(String maxPoolSize) |
Sets the maximum pool size
|
ThreadsDefinition |
ThreadsDefinition.maxQueueSize(int maxQueueSize) |
Sets the maximum number of tasks in the work queue.
|
ThreadsDefinition |
ThreadsDefinition.maxQueueSize(String maxQueueSize) |
Sets the maximum number of tasks in the work queue.
|
ThreadsDefinition |
ThreadsDefinition.poolSize(int poolSize) |
Sets the core pool size
|
ThreadsDefinition |
ThreadsDefinition.poolSize(String poolSize) |
Sets the core pool size
|
ThreadsDefinition |
ThreadsDefinition.rejectedPolicy(String rejectedPolicy) |
Sets the handler for tasks which cannot be executed by the thread pool.
|
ThreadsDefinition |
ThreadsDefinition.rejectedPolicy(org.apache.camel.util.concurrent.ThreadPoolRejectedPolicy rejectedPolicy) |
Sets the handler for tasks which cannot be executed by the thread pool.
|
ThreadsDefinition |
ThreadsDefinition.threadName(String threadName) |
Sets the thread name to use.
|
ThreadsDefinition |
ProcessorDefinition.threads() |
Continues processing the Exchange using asynchronous routing engine.
|
ThreadsDefinition |
ProcessorDefinition.threads(int poolSize) |
Continues processing the Exchange using asynchronous routing engine.
|
ThreadsDefinition |
ProcessorDefinition.threads(int poolSize,
int maxPoolSize) |
Continues processing the Exchange using asynchronous routing engine.
|
ThreadsDefinition |
ProcessorDefinition.threads(int poolSize,
int maxPoolSize,
String threadName) |
Continues processing the Exchange using asynchronous routing engine.
|
ThreadsDefinition |
ThreadsDefinition.timeUnit(String keepAliveTimeUnits) |
Sets the keep alive time unit.
|
ThreadsDefinition |
ThreadsDefinition.timeUnit(TimeUnit keepAliveTimeUnits) |
Sets the keep alive time unit.
|