Package | Description |
---|---|
org.apache.camel.builder | |
org.apache.camel.model |
The JAXB POJOs for the
XML Configuration
of the routing rules.
|
org.apache.camel.processor |
A collection of Processor
implementations which are used to implement the
Enterprise Integration Patterns
|
Modifier and Type | Field and Description |
---|---|
protected RedeliveryPolicy |
DefaultErrorHandlerBuilder.redeliveryPolicy |
Modifier and Type | Method and Description |
---|---|
protected RedeliveryPolicy |
DeadLetterChannelBuilder.createRedeliveryPolicy() |
protected RedeliveryPolicy |
DefaultErrorHandlerBuilder.createRedeliveryPolicy() |
RedeliveryPolicy |
DefaultErrorHandlerBuilder.getRedeliveryPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultErrorHandlerBuilder.setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
Sets the redelivery policy
|
Modifier and Type | Method and Description |
---|---|
RedeliveryPolicy |
OnExceptionDefinition.createRedeliveryPolicy(CamelContext context,
RedeliveryPolicy parentPolicy)
Allows an exception handler to create a new redelivery policy for this exception type
|
RedeliveryPolicy |
RedeliveryPolicyDefinition.createRedeliveryPolicy(CamelContext context,
RedeliveryPolicy parentPolicy) |
Modifier and Type | Method and Description |
---|---|
RedeliveryPolicy |
OnExceptionDefinition.createRedeliveryPolicy(CamelContext context,
RedeliveryPolicy parentPolicy)
Allows an exception handler to create a new redelivery policy for this exception type
|
RedeliveryPolicy |
RedeliveryPolicyDefinition.createRedeliveryPolicy(CamelContext context,
RedeliveryPolicy parentPolicy) |
OnExceptionDefinition |
OnExceptionDefinition.redeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
Set the
RedeliveryPolicy to be used. |
Modifier and Type | Field and Description |
---|---|
protected RedeliveryPolicy |
RedeliveryErrorHandler.redeliveryPolicy |
Modifier and Type | Method and Description |
---|---|
RedeliveryPolicy |
RedeliveryPolicy.allowRedeliveryWhileStopping(boolean redeliverWhileStopping)
Controls whether to allow redelivery while stopping/shutting down a route that uses error handling.
|
RedeliveryPolicy |
RedeliveryPolicy.asyncDelayedRedelivery()
Allow asynchronous delayed redelivery.
|
RedeliveryPolicy |
RedeliveryPolicy.backOffMultiplier(double multiplier)
Enables exponential backoff and sets the multiplier used to increase the
delay between redeliveries
|
RedeliveryPolicy |
RedeliveryPolicy.collisionAvoidancePercent(double collisionAvoidancePercent)
Enables collision avoidance and sets the percentage used
|
RedeliveryPolicy |
RedeliveryPolicy.copy() |
RedeliveryPolicy |
RedeliveryPolicy.delayPattern(String delayPattern)
Sets the delay pattern with delay intervals.
|
RedeliveryPolicy |
RedeliveryPolicy.disableRedelivery()
Disables redelivery by setting maximum redeliveries to 0.
|
RedeliveryPolicy |
RedeliveryPolicy.exchangeFormatterRef(String exchangeFormatterRef)
Sets the reference of the instance of
ExchangeFormatter to generate the log message from exchange. |
RedeliveryPolicy |
RedeliveryErrorHandler.getRedeliveryPolicy() |
RedeliveryPolicy |
RedeliveryPolicy.logExhausted(boolean logExhausted)
Sets whether to log exhausted errors
|
RedeliveryPolicy |
RedeliveryPolicy.logExhaustedMessageHistory(boolean logExhaustedMessageHistory)
Sets whether to log exhausted errors including message history
|
RedeliveryPolicy |
RedeliveryPolicy.logHandled(boolean logHandled)
Sets whether to log errors even if its handled
|
RedeliveryPolicy |
RedeliveryPolicy.logNewException(boolean logNewException)
Sets whether errors should be logged when a new exception occurred during handling a previous exception
|
RedeliveryPolicy |
RedeliveryPolicy.logRetryAttempted(boolean logRetryAttempted)
Sets whether to log retry attempts
|
RedeliveryPolicy |
RedeliveryPolicy.logRetryStackTrace(boolean logRetryStackTrace)
Sets whether to log stacktrace for failed redelivery attempts
|
RedeliveryPolicy |
RedeliveryPolicy.logStackTrace(boolean logStackTrace)
Sets whether to log stacktrace for failed messages.
|
RedeliveryPolicy |
RedeliveryPolicy.maximumRedeliveries(int maximumRedeliveries)
Sets the maximum number of times a message exchange will be redelivered
|
RedeliveryPolicy |
RedeliveryPolicy.maximumRedeliveryDelay(long maximumRedeliveryDelay)
Sets the maximum redelivery delay if using exponential back off.
|
RedeliveryPolicy |
RedeliveryPolicy.redeliverDelay(long delay)
Deprecated.
will be removed in the near future. Instead use
redeliveryDelay(long) instead |
RedeliveryPolicy |
RedeliveryPolicy.redeliveryDelay(long delay)
Sets the initial redelivery delay in milliseconds
|
RedeliveryPolicy |
RedeliveryPolicy.retriesExhaustedLogLevel(LoggingLevel retriesExhaustedLogLevel)
Sets the logging level to use for log messages when retries have been exhausted.
|
RedeliveryPolicy |
RedeliveryPolicy.retryAttemptedLogLevel(LoggingLevel retryAttemptedLogLevel)
Sets the logging level to use for log messages when retries are attempted.
|
RedeliveryPolicy |
RedeliveryPolicy.useCollisionAvoidance()
Enables collision avoidance which adds some randomization to the backoff
timings to reduce contention probability
|
RedeliveryPolicy |
RedeliveryPolicy.useExponentialBackOff()
Enables exponential backoff using the
getBackOffMultiplier() to
increase the time between retries |
Modifier and Type | Method and Description |
---|---|
protected long |
RedeliveryErrorHandler.determineRedeliveryDelay(Exchange exchange,
RedeliveryPolicy redeliveryPolicy,
long redeliveryDelay,
int redeliveryCounter)
Determines the redelivery delay time by first inspecting the Message header
Exchange.REDELIVERY_DELAY
and if not present, defaulting to calculateRedeliveryDelay(long, int) |
Constructor and Description |
---|
DeadLetterChannel(CamelContext camelContext,
Processor output,
CamelLogger logger,
Processor redeliveryProcessor,
RedeliveryPolicy redeliveryPolicy,
ExceptionPolicyStrategy exceptionPolicyStrategy,
Processor deadLetter,
String deadLetterUri,
boolean deadLetterHandleException,
boolean useOriginalBodyPolicy,
Predicate retryWhile,
ScheduledExecutorService executorService)
Creates the dead letter channel.
|
DefaultErrorHandler(CamelContext camelContext,
Processor output,
CamelLogger logger,
Processor redeliveryProcessor,
RedeliveryPolicy redeliveryPolicy,
ExceptionPolicyStrategy exceptionPolicyStrategy,
Predicate retryWhile,
ScheduledExecutorService executorService)
Creates the default error handler.
|
LoggingErrorHandler(CamelContext camelContext,
Processor output,
CamelLogger logger,
RedeliveryPolicy redeliveryPolicy,
ExceptionPolicyStrategy exceptionPolicyStrategy)
Creates the logging error handler.
|
RedeliveryErrorHandler(CamelContext camelContext,
Processor output,
CamelLogger logger,
Processor redeliveryProcessor,
RedeliveryPolicy redeliveryPolicy,
Processor deadLetter,
String deadLetterUri,
boolean deadLetterHandleNewException,
boolean useOriginalMessagePolicy,
Predicate retryWhile,
ScheduledExecutorService executorService) |
Apache Camel