Interface StreamMessageRecoverer

All Superinterfaces:
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 MessageRecoverer
Implementations of this interface can handle failed messages after retries are exhausted.
Since:
2.4.5
Author:
Gary Russell

  • Method Summary

    Modifier and Type
    Method
    Description
    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.
    default void
    recover(Message message, @Nullable Throwable cause)
    Callback for message that was consumed but failed all retry attempts.

  • Method Details

    • recover

      default void recover(Message message, @Nullable 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

    • 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.