org.springframework.amqp.rabbit.retry
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

RejectAndDontRequeueRecoverer()

Method Summary

void	recover(Message message, java.lang.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

Constructor Detail

RejectAndDontRequeueRecoverer

public RejectAndDontRequeueRecoverer()

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 interface MessageRecoverer

Parameters:

message - the message to recover

cause - the cause of the error