Class ContainerUtils

java.lang.Object

org.springframework.amqp.listener.ContainerUtils

public final class ContainerUtils
extends Object

Utility methods for listener containers.

Since:

4.1

Author:

Gary Russell, Artem Bilan

Method Summary

Modifier and Type	Method	Description
static boolean	isAmqpReject(Throwable ex)	Return true for AmqpRejectAndDontRequeueException.
static boolean	isImmediateAcknowledge(Throwable ex)	Return true for ImmediateAcknowledgeAmqpException.
static boolean	isRejectManual(Throwable ex)	Return true for AmqpRejectAndDontRequeueException.isRejectManual().
static boolean	shouldRequeue(boolean defaultRequeueRejected, Throwable throwable, org.apache.commons.logging.Log logger)	Determine whether a message should be requeued; returns true if the throwable is a MessageRejectedWhileStoppingException or defaultRequeueRejected is true and there is not an AmqpRejectAndDontRequeueException in the cause chain or if there is an ImmediateRequeueAmqpException in the cause chain.

Methods inherited from class java.lang.Object

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

Method Details

shouldRequeue

public static boolean shouldRequeue(boolean defaultRequeueRejected,
 Throwable throwable,
 org.apache.commons.logging.Log logger)

Determine whether a message should be requeued; returns true if the throwable is a MessageRejectedWhileStoppingException or defaultRequeueRejected is true and there is not an AmqpRejectAndDontRequeueException in the cause chain or if there is an ImmediateRequeueAmqpException in the cause chain.

Parameters:

defaultRequeueRejected - the default requeue rejected.

throwable - the throwable.

logger - the logger to use for debug.

Returns:

true to requeue.

isRejectManual

public static boolean isRejectManual(Throwable ex)

Return true for AmqpRejectAndDontRequeueException.isRejectManual().

Parameters:

ex - the exception.

Returns:

the exception's rejectManual property, if it's an AmqpRejectAndDontRequeueException.

isImmediateAcknowledge

public static boolean isImmediateAcknowledge(Throwable ex)

Return true for ImmediateAcknowledgeAmqpException.

Parameters:

ex - the exception to traverse.

Returns:

true if an ImmediateAcknowledgeAmqpException is present in the cause chain.

isAmqpReject

public static boolean isAmqpReject(Throwable ex)

Return true for AmqpRejectAndDontRequeueException.

Parameters:

ex - the exception to traverse.

Returns:

true if an AmqpRejectAndDontRequeueException is present in the cause chain.