public class RejectAndDontRequeueRecoverer extends java.lang.Object implements MessageRecoverer
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.commons.logging.Log |
logger |
| Constructor and Description |
|---|
RejectAndDontRequeueRecoverer()
Construct an instance with the default exception message.
|
RejectAndDontRequeueRecoverer(java.lang.String message)
Construct an instance with the provided exception message.
|
RejectAndDontRequeueRecoverer(java.util.function.Supplier<java.lang.String> messageSupplier)
Construct an instance with the provided exception message supplier.
|
| Modifier and Type | Method and Description |
|---|---|
void |
recover(org.springframework.amqp.core.Message message,
java.lang.Throwable cause)
Callback for message that was consumed but failed all retry attempts.
|
public RejectAndDontRequeueRecoverer()
public RejectAndDontRequeueRecoverer(java.lang.String message)
message - the message.public RejectAndDontRequeueRecoverer(java.util.function.Supplier<java.lang.String> messageSupplier)
messageSupplier - the message supplier.public void recover(org.springframework.amqp.core.Message message,
java.lang.Throwable cause)
MessageRecovererrecover in interface MessageRecoverermessage - the message to recovercause - the cause of the error