public final class AckUtils
extends java.lang.Object
AcknowledgmentCallback headers.| Modifier and Type | Method and Description |
|---|---|
static void |
accept(AcknowledgmentCallback ackCallback)
ACCEPT the associated message if the callback is not null.
|
static void |
autoAck(AcknowledgmentCallback ackCallback)
ACCEPT an
AcknowledgmentCallback if it's not null, supports auto ack
and is not already ack'd. |
static void |
autoNack(AcknowledgmentCallback ackCallback)
REJECT an
AcknowledgmentCallback if it's not null, supports auto ack
and is not already ack'd. |
static AcknowledgmentCallback |
getAckCallback(org.springframework.messaging.Message<?> message)
Return the
AcknowledgmentCallback header (if present). |
static void |
reject(AcknowledgmentCallback ackCallback)
REJECT the associated message if the callback is not null.
|
static void |
requeue(AcknowledgmentCallback ackCallback)
REQUEUE the associated message if the callback is not null.
|
@Nullable public static AcknowledgmentCallback getAckCallback(org.springframework.messaging.Message<?> message)
AcknowledgmentCallback header (if present).message - the message.public static void autoAck(AcknowledgmentCallback ackCallback)
AcknowledgmentCallback if it's not null, supports auto ack
and is not already ack'd.ackCallback - the callback.public static void autoNack(AcknowledgmentCallback ackCallback)
AcknowledgmentCallback if it's not null, supports auto ack
and is not already ack'd.ackCallback - the callback.public static void accept(@Nullable
AcknowledgmentCallback ackCallback)
ackCallback - the callback.public static void reject(@Nullable
AcknowledgmentCallback ackCallback)
ackCallback - the callback.public static void requeue(@Nullable
AcknowledgmentCallback ackCallback)
ackCallback - the callback.