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 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​(org.springframework.amqp.core.Message message, java.lang.Throwable cause)  
    • Method Detail

      • recover

        default void recover​(org.springframework.amqp.core.Message message,
                             java.lang.Throwable cause)
        Specified by:
        recover in interface org.springframework.amqp.rabbit.retry.MessageRecoverer
      • 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.