Interface StreamMessageRecoverer
- All Superinterfaces:
org.springframework.amqp.rabbit.retry.MessageRecoverer
- 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 StreamMessageRecoverer
extends org.springframework.amqp.rabbit.retry.MessageRecoverer
Implementations of this interface can handle failed messages after retries are
exhausted.
- Since:
- 2.4.5
-
Method Details
-
recover
- Specified by:
recoverin interfaceorg.springframework.amqp.rabbit.retry.MessageRecoverer
-
recover
void recover(com.rabbitmq.stream.Message message, com.rabbitmq.stream.MessageHandler.Context context, Throwable cause) Callback for message that was consumed but failed all retry attempts.- Parameters:
message- the message to recover.context- the context.cause- the cause of the error.
-