Package org.springframework.amqp.rabbit.retry

Class ImmediateRequeueMessageRecoverer

java.lang.Object

org.springframework.amqp.rabbit.retry.ImmediateRequeueMessageRecoverer

All Implemented Interfaces:

MessageRecoverer

public class ImmediateRequeueMessageRecoverer
extends Object
implements MessageRecoverer

The MessageRecoverer implementation to throw an ImmediateRequeueAmqpException for subsequent requeuing in the listener container.

Since:

2.1

Author:

Artem Bilan, Gary Russell

Field Summary

Fields

Modifier and Type	Field	Description
protected Log	logger

Constructor Summary

Constructors

Constructor	Description
ImmediateRequeueMessageRecoverer()

Method Summary

Modifier and Type	Method	Description
void	recover(Message message, Throwable cause)	Callback for message that was consumed but failed all retry attempts.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

protected Log logger

Constructor Details

ImmediateRequeueMessageRecoverer

public ImmediateRequeueMessageRecoverer()

Method Details

recover

public void recover(Message message,
 Throwable cause)

Description copied from interface: MessageRecoverer

Callback for message that was consumed but failed all retry attempts.

Specified by:

recover in interface MessageRecoverer

Parameters:

message - the message to recover

cause - the cause of the error