Class ConditionalRejectingErrorHandler

java.lang.Object
org.springframework.amqp.listener.ConditionalRejectingErrorHandler
All Implemented Interfaces:
org.springframework.util.ErrorHandler
public 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, MessageConversionException, MethodArgumentNotValidException, MethodArgumentTypeMismatchException, NoSuchMethodException or ClassCastException.

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

If setStopListenerOnFatal(boolean) is true, a FatalListenerExecutionException is thrown instead of an AmqpRejectAndDontRequeueException. The listener container must be stopped due to such a fatal state, and the message requeued for other consumers on the destination.

Since:
4.1

  • Field Details

    • logger

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

  • Constructor Details

  • Method Details

    • isDiscardFatalsWithXDeath

      protected boolean isDiscardFatalsWithXDeath()
      Return the discardFatalsWithXDeath.
      Returns:
      the discardFatalsWithXDeath.
      See Also:

    • setDiscardFatalsWithXDeath

      public void setDiscardFatalsWithXDeath(boolean discardFatalsWithXDeath)
      Set to false to disable the (now) default behavior of logging and discarding messages that cause fatal exceptions and have an `x-death` header; which usually means that the message has been republished after previously being sent to a DLQ.
      Parameters:
      discardFatalsWithXDeath - false to disable.

    • isRejectManual

      protected boolean isRejectManual()
      Return the rejectManual.
      Returns:
      the rejectManual.
      See Also:

    • setRejectManual

      public void setRejectManual(boolean rejectManual)
      Set to false to NOT reject a fatal message when MANUAL ack mode is being used.
      Parameters:
      rejectManual - false to leave the message in an unack'd state.

    • getExceptionStrategy

      protected FatalExceptionStrategy getExceptionStrategy()
      Return the exception strategy.
      Returns:
      the strategy.

    • setStopListenerOnFatal

      public void setStopListenerOnFatal(boolean stopListenerOnFatal)
      Set to true to throw a FatalListenerExecutionException on fatal error instead of a AmqpRejectAndDontRequeueException.
      Parameters:
      stopListenerOnFatal - true to throw a FatalListenerExecutionException
      Since:
      4.1

    • isStopListenerOnFatal

      protected boolean isStopListenerOnFatal()

    • handleError

      public void handleError(Throwable t)
      Specified by:
      handleError in interface org.springframework.util.ErrorHandler

    • handleDiscarded

      protected void handleDiscarded(Message failed)
      Called when a message with a fatal exception has an x-death header, prior to discarding the message. Subclasses can override this method to perform some action, such as sending the message to a parking queue.
      Parameters:
      failed - the failed message.

    • log

      protected void log(Throwable throwable)
      Log the throwable at WARN level, including stack trace. Subclasses can override this behavior.
      Parameters:
      throwable - the Throwable.

    • causeChainContainsARADRE

      protected boolean causeChainContainsARADRE(Throwable throwable)
      Return true if there is already an AmqpRejectAndDontRequeueException present in the cause chain.
      Parameters:
      throwable - a Throwable.
      Returns:
      true if the cause chain already contains an AmqpRejectAndDontRequeueException.