public class RejectAndDontRequeueRecoverer extends java.lang.Object implements MessageRecoverer
| Constructor and Description |
|---|
RejectAndDontRequeueRecoverer() |
| 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 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