public class DefaultErrorHandler extends RedeliveryErrorHandler
RedeliveryErrorHandler.RedeliveryDatacamelContext, customExchangeFormatter, deadLetter, deadLetterHandleNewException, deadLetterUri, exchangeFormatter, executorService, logger, onExceptionProcessor, onPrepareProcessor, output, outputAsync, preparingShutdown, redeliveryEnabled, redeliveryPolicy, redeliveryProcessor, redeliverySleepCounter, retryWhilePolicy, useOriginalMessagePolicyexceptionPolicies, exceptionPolicy, logshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
DefaultErrorHandler(CamelContext camelContext,
Processor output,
CamelLogger logger,
Processor redeliveryProcessor,
RedeliveryPolicy redeliveryPolicy,
ExceptionPolicyStrategy exceptionPolicyStrategy,
Predicate retryWhile,
ScheduledExecutorService executorService,
Processor onPrepareProcessor,
Processor onExceptionOccurredProcessor)
Creates the default error handler.
|
| Modifier and Type | Method and Description |
|---|---|
void |
process(Exchange exchange)
Processes the message exchange
|
String |
toString() |
defensiveCopyExchangeIfNeeded, deliverToFailureProcessor, deliverToOnRedeliveryProcessor, determineRedeliveryDelay, doShutdown, doStart, doStop, getDeadLetter, getDeadLetterUri, getDefaultHandledPredicate, getLogger, getOutput, getPendingRedeliveryCount, getRedeliveryPolicy, handleException, hasNext, isCancelledOrInterrupted, isDeadLetterHandleNewException, isDone, isRedeliveryAllowed, isRunAllowed, isRunAllowedOnPreparingShutdown, isUseOriginalMessagePolicy, next, onExceptionOccurred, prepareExchangeAfterFailure, prepareExchangeForContinue, prepareExchangeForRedelivery, prepareShutdown, process, processAsyncErrorHandler, shouldHandleException, supportTransactedaddExceptionPolicy, createDefaultExceptionPolicyStrategy, getExceptionPolicy, isDeadLetterChannel, setExceptionPolicyaddChildService, removeChildService, shutdown, start, start, stopdoResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, suspendpublic DefaultErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, ExceptionPolicyStrategy exceptionPolicyStrategy, Predicate retryWhile, ScheduledExecutorService executorService, Processor onPrepareProcessor, Processor onExceptionOccurredProcessor)
camelContext - the camel contextoutput - outer processor that should use this default error handlerlogger - logger to use for logging failures and redelivery attemptsredeliveryProcessor - an optional processor to run before redelivery attemptredeliveryPolicy - policy for redeliveryexceptionPolicyStrategy - strategy for onException handlingretryWhile - retry whileexecutorService - the ScheduledExecutorService to be used for redelivery thread pool. Can be null.onPrepareProcessor - a custom Processor to prepare the Exchange before
handled by the failure processor / dead letter channel.onExceptionOccurredProcessor - a custom Processor to process the Exchange just after an exception was thrown.public void process(Exchange exchange) throws Exception
Processorprocess in interface Processorprocess in class RedeliveryErrorHandlerexchange - the message exchangeException - if an internal processing error has occurred.Apache Camel