Class ImmediateRequeueMessageRecoverer
- java.lang.Object
-
- org.springframework.amqp.rabbit.retry.ImmediateRequeueMessageRecoverer
-
- All Implemented Interfaces:
MessageRecoverer
public class ImmediateRequeueMessageRecoverer extends java.lang.Object implements MessageRecoverer
TheMessageRecovererimplementation to throw anImmediateRequeueAmqpExceptionfor subsequent requeuing in the listener container.- Since:
- 2.1
-
-
Field Summary
Fields Modifier and Type Field Description protected org.apache.commons.logging.Loglogger
-
Constructor Summary
Constructors Constructor Description ImmediateRequeueMessageRecoverer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidrecover(org.springframework.amqp.core.Message message, java.lang.Throwable cause)Callback for message that was consumed but failed all retry attempts.
-
-
-
Method Detail
-
recover
public void recover(org.springframework.amqp.core.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
-
-