Package org.springframework.amqp.rabbit.retry

Interface MessageRecoverer

All Known Subinterfaces:

MessageBatchRecoverer, StreamMessageRecoverer

All Known Implementing Classes:

ImmediateRequeueMessageRecoverer, RejectAndDontRequeueRecoverer, RepublishMessageRecoverer, RepublishMessageRecovererWithConfirms

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface MessageRecoverer

Implementations of this interface can handle failed messages after retries are exhausted.

Author:

Dave Syer, Gary Russell

Method Summary

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

Method Detail

recover

void recover(Message message,
             java.lang.Throwable cause)

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

Parameters:

message - the message to recover

cause - the cause of the error