org.springframework.amqp.rabbit.listener

Class ConditionalRejectingErrorHandler

java.lang.Object

org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler

All Implemented Interfaces:

org.springframework.util.ErrorHandler

public final class ConditionalRejectingErrorHandler
extends Object
implements org.springframework.util.ErrorHandler

ErrorHandler that conditionally wraps the Exception in an AmqpRejectAndDontRequeueException if the configured rejection strategy determines that the message is fatal and should not be requeued. Such messages will be discarded or sent to a Dead Letter Exchange, depending on broker configuration.

The default strategy will do this if the exception is a ListenerExecutionFailedException with a cause of MessageConversionException.

The exception will not be wrapped if the cause chain already contains an AmqpRejectAndDontRequeueException.

Since:

1.3.2

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor and Description
ConditionalRejectingErrorHandler() Create a handler with the ConditionalRejectingErrorHandler.DefaultExceptionStrategy.
ConditionalRejectingErrorHandler(FatalExceptionStrategy exceptionStrategy) Create a handler with the supplied FatalExceptionStrategy implementation.

Method Summary

Methods

Modifier and Type	Method and Description
void	handleError(Throwable t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected static final org.apache.commons.logging.Log logger

Constructor Detail

ConditionalRejectingErrorHandler

public ConditionalRejectingErrorHandler()

Create a handler with the ConditionalRejectingErrorHandler.DefaultExceptionStrategy.

ConditionalRejectingErrorHandler

public ConditionalRejectingErrorHandler(FatalExceptionStrategy exceptionStrategy)

Create a handler with the supplied FatalExceptionStrategy implementation.

Parameters:

exceptionStrategy - The strategy implementation.

Method Detail

handleError

public void handleError(Throwable t)

Specified by:

handleError in interface org.springframework.util.ErrorHandler