Class RejectAndDontRequeueRecoverer
- java.lang.Object
-
- org.springframework.amqp.rabbit.retry.RejectAndDontRequeueRecoverer
-
- All Implemented Interfaces:
MessageRecoverer
public class RejectAndDontRequeueRecoverer extends java.lang.Object implements MessageRecoverer
MessageRecover that causes the listener container to reject the message without requeuing. This enables failed messages to be sent to a Dead Letter Exchange/Queue, if the broker is so configured.- Since:
- 1.1.2
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Constructor 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.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidrecover(Message message, java.lang.Throwable cause)Callback for message that was consumed but failed all retry attempts.
-
-
-
Field Detail
-
logger
protected final Log logger
-
-
Constructor Detail
-
RejectAndDontRequeueRecoverer
public RejectAndDontRequeueRecoverer()
Construct an instance with the default exception message.
-
RejectAndDontRequeueRecoverer
public RejectAndDontRequeueRecoverer(java.lang.String message)
Construct an instance with the provided exception message.- Parameters:
message- the message.- Since:
- 2.3.7
-
RejectAndDontRequeueRecoverer
public RejectAndDontRequeueRecoverer(java.util.function.Supplier<java.lang.String> messageSupplier)
Construct an instance with the provided exception message supplier.- Parameters:
messageSupplier- the message supplier.- Since:
- 2.3.7
-
-
Method Detail
-
recover
public void recover(Message message, java.lang.Throwable cause)
Description copied from interface:MessageRecovererCallback for message that was consumed but failed all retry attempts.- Specified by:
recoverin interfaceMessageRecoverer- Parameters:
message- the message to recovercause- the cause of the error
-
-