ThrottleDefinition |
ThrottleDefinition.asyncDelayed() |
Enables asynchronous delay which means the thread will not block while delaying.
|
ThrottleDefinition |
ThrottleDefinition.asyncDelayed(boolean asyncDelayed) |
Enables asynchronous delay which means the thread will not block while delaying.
|
ThrottleDefinition |
ThrottleDefinition.asyncDelayed(String asyncDelayed) |
Enables asynchronous delay which means the thread will not block while delaying.
|
ThrottleDefinition |
ThrottleDefinition.callerRunsWhenRejected(boolean callerRunsWhenRejected) |
Whether or not the caller should run the task when it was rejected by the thread pool.
|
ThrottleDefinition |
ThrottleDefinition.callerRunsWhenRejected(String callerRunsWhenRejected) |
Whether or not the caller should run the task when it was rejected by the thread pool.
|
ThrottleDefinition |
ThrottleDefinition.executorService(ExecutorService executorService) |
To use a custom thread pool (ScheduledExecutorService) by the throttler.
|
ThrottleDefinition |
ThrottleDefinition.executorServiceRef(String executorServiceRef) |
To use a custom thread pool (ScheduledExecutorService) by the throttler.
|
ThrottleDefinition |
ThrottleDefinition.maximumRequestsPerPeriod(long maximumRequestsPerPeriod) |
Sets the time period during which the maximum request count per period
|
ThrottleDefinition |
ThrottleDefinition.maximumRequestsPerPeriod(String maximumRequestsPerPeriod) |
Sets the time period during which the maximum request count per period
|
ThrottleDefinition |
ThrottleDefinition.rejectExecution(boolean rejectExecution) |
Whether or not throttler throws the ThrottlerRejectedExecutionException when the exchange exceeds the request
limit
|
ThrottleDefinition |
ThrottleDefinition.rejectExecution(String rejectExecution) |
Whether or not throttler throws the ThrottlerRejectedExecutionException when the exchange exceeds the request
limit
|
ThrottleDefinition |
ProcessorDefinition.throttle(long maximumRequestCount) |
Throttler EIP: Creates a throttler allowing you to ensure
that a specific endpoint does not get overloaded, or that we don't exceed an agreed SLA with some external
service.
|
ThrottleDefinition |
ProcessorDefinition.throttle(org.apache.camel.Expression maximumRequestCount) |
Throttler EIP: Creates a throttler allowing you to ensure
that a specific endpoint does not get overloaded, or that we don't exceed an agreed SLA with some external
service.
|
ThrottleDefinition |
ProcessorDefinition.throttle(org.apache.camel.Expression maximumRequestCount,
long correlationExpressionKey) |
Throttler EIP: Creates a throttler allowing you to ensure
that a specific endpoint does not get overloaded, or that we don't exceed an agreed SLA with some external
service.
|
ThrottleDefinition |
ProcessorDefinition.throttle(org.apache.camel.Expression maximumRequestCount,
org.apache.camel.Expression correlationExpressionKey) |
Throttler EIP: Creates a throttler allowing you to ensure
that a specific endpoint does not get overloaded, or that we don't exceed an agreed SLA with some external
service.
|
ThrottleDefinition |
ThrottleDefinition.timePeriodMillis(long timePeriodMillis) |
Sets the time period during which the maximum request count is valid for
|
ThrottleDefinition |
ThrottleDefinition.timePeriodMillis(String timePeriodMillis) |
Sets the time period during which the maximum request count is valid for
|