Package org.springframework.rabbit.stream.retry

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

      All Methods Instance Methods Abstract Methods Default Methods 
      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, Throwable cause)
      Callback for message that was consumed but failed all retry attempts.

    • Method Detail

      • recover

        default void recover​(Message message,
                     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.