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, java.lang.Throwable cause)
      Callback for message that was consumed but failed all retry attempts.
      default void recover​(Message message, java.lang.Throwable cause)
      Callback for message that was consumed but failed all retry attempts.
    • Method Detail

      • recover

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