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
.