@FunctionalInterface public interface MessageBatchRecoverer extends MessageRecoverer
| Modifier and Type | Method and Description |
|---|---|
void |
recover(java.util.List<org.springframework.amqp.core.Message> messages,
java.lang.Throwable cause)
Callback for message batch that was consumed but failed all retry attempts.
|
default void |
recover(org.springframework.amqp.core.Message message,
java.lang.Throwable cause)
Callback for message that was consumed but failed all retry attempts.
|
default void recover(org.springframework.amqp.core.Message message,
java.lang.Throwable cause)
MessageRecovererrecover in interface MessageRecoverermessage - the message to recovercause - the cause of the errorvoid recover(java.util.List<org.springframework.amqp.core.Message> messages,
java.lang.Throwable cause)
messages - the messages to recovercause - the cause of the error