public final class ContainerUtils extends Object
| Modifier and Type | Method and Description |
|---|---|
static boolean |
isRejectManual(Throwable ex)
Return true for
AmqpRejectAndDontRequeueException.isRejectManual(). |
static boolean |
shouldRequeue(boolean defaultRequeueRejected,
Throwable throwable,
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. |
public static boolean shouldRequeue(boolean defaultRequeueRejected,
Throwable throwable,
Log logger)
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.defaultRequeueRejected - the default requeue rejected.throwable - the throwable.logger - the logger to use for debug.public static boolean isRejectManual(Throwable ex)
AmqpRejectAndDontRequeueException.isRejectManual().ex - the exception.AmqpRejectAndDontRequeueException.