|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.impl.ServiceSupport
org.apache.camel.processor.ErrorHandlerSupport
org.apache.camel.processor.DeadLetterChannel
public class DeadLetterChannel
Implements a Dead Letter
Channel after attempting to redeliver the message using the
RedeliveryPolicy
Field Summary |
---|
Fields inherited from class org.apache.camel.processor.ErrorHandlerSupport |
---|
log |
Constructor Summary | |
---|---|
DeadLetterChannel(Processor output,
Processor deadLetter,
String deadLetterUri,
Processor redeliveryProcessor,
RedeliveryPolicy redeliveryPolicy,
Logger logger,
ExceptionPolicyStrategy exceptionPolicyStrategy,
Predicate handledPolicy,
boolean useOriginalBodyPolicy)
Creates the dead letter channel. |
Method Summary | |
---|---|
protected void |
doStart()
|
protected void |
doStop()
|
Processor |
getDeadLetter()
Returns the dead letter that message exchanges will be sent to if the redelivery attempts fail |
Logger |
getLogger()
|
Processor |
getOutput()
Returns the output processor |
RedeliveryPolicy |
getRedeliveryPolicy()
|
void |
process(Exchange exchange)
Processes the message exchange |
protected void |
processErrorHandler(Exchange exchange,
org.apache.camel.processor.DeadLetterChannel.RedeliveryData data)
Processes the exchange decorated with this dead letter channel. |
boolean |
supportTransacted()
Whether this error handler supports transacted exchanges or not. |
String |
toString()
|
Methods inherited from class org.apache.camel.processor.ErrorHandlerSupport |
---|
addExceptionPolicy, createDefaultExceptionPolicyStrategy, customProcessorForException, getExceptionPolicy, setExceptionPolicy |
Methods inherited from class org.apache.camel.impl.ServiceSupport |
---|
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public DeadLetterChannel(Processor output, Processor deadLetter, String deadLetterUri, Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, Logger logger, ExceptionPolicyStrategy exceptionPolicyStrategy, Predicate handledPolicy, boolean useOriginalBodyPolicy)
output
- outer processor that should use this dead letter channeldeadLetter
- the failure processor to send failed exchanges todeadLetterUri
- an optional uri for logging purposeredeliveryProcessor
- an optional processor to run before redelivert attemptredeliveryPolicy
- policy for redeliverylogger
- logger to use for logging failures and redelivery attemptsexceptionPolicyStrategy
- strategy for onException handlinghandledPolicy
- policy for handling failed exception that are moved to the dead letter queueuseOriginalBodyPolicy
- should the original IN body be moved to the dead letter queue or the current exchange IN body?Method Detail |
---|
public String toString()
toString
in class Object
public boolean supportTransacted()
ErrorHandlerSupport
supportTransacted
in class ErrorHandlerSupport
public void process(Exchange exchange) throws Exception
Processor
process
in interface Processor
exchange
- the message exchange
Exception
- if an internal processing error has occurred.protected void processErrorHandler(Exchange exchange, org.apache.camel.processor.DeadLetterChannel.RedeliveryData data)
public Processor getOutput()
public Processor getDeadLetter()
public RedeliveryPolicy getRedeliveryPolicy()
public Logger getLogger()
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class ServiceSupport
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |