Class ImmediateRequeueMessageRecoverer
- java.lang.Object
-
- org.springframework.amqp.rabbit.retry.ImmediateRequeueMessageRecoverer
-
- All Implemented Interfaces:
MessageRecoverer
public class ImmediateRequeueMessageRecoverer extends java.lang.Object implements MessageRecoverer
TheMessageRecoverer
implementation to throw anImmediateRequeueAmqpException
for subsequent requeuing in the listener container.- Since:
- 2.1
- Author:
- Artem Bilan, Gary Russell
-
-
Constructor Summary
Constructors Constructor Description ImmediateRequeueMessageRecoverer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
recover(Message message, java.lang.Throwable cause)
Callback for message that was consumed but failed all retry attempts.
-
-
-
Field Detail
-
logger
protected Log logger
-
-
Method Detail
-
recover
public void recover(Message message, java.lang.Throwable cause)
Description copied from interface:MessageRecoverer
Callback for message that was consumed but failed all retry attempts.- Specified by:
recover
in interfaceMessageRecoverer
- Parameters:
message
- the message to recovercause
- the cause of the error
-
-