Class BatchCapableRejectAndDontRequeueRecoverer

java.lang.Object
org.springframework.cloud.stream.binder.rabbit.BatchCapableRejectAndDontRequeueRecoverer
All Implemented Interfaces:
org.springframework.amqp.rabbit.retry.MessageBatchRecoverer, org.springframework.amqp.rabbit.retry.MessageRecoverer
public class BatchCapableRejectAndDontRequeueRecoverer extends Object implements org.springframework.amqp.rabbit.retry.MessageBatchRecoverer

  • Field Details

    • logger

      protected final org.apache.commons.logging.Log logger

  • Constructor Details

    • BatchCapableRejectAndDontRequeueRecoverer

      public BatchCapableRejectAndDontRequeueRecoverer()

    • BatchCapableRejectAndDontRequeueRecoverer

      public BatchCapableRejectAndDontRequeueRecoverer(Supplier<String> messageSupplier)
      Construct an instance with the provided exception message supplier.
      Parameters:
      messageSupplier - the message supplier.

  • Method Details

    • recover

      public void recover(List<org.springframework.amqp.core.Message> messages, Throwable cause)
      Specified by:
      recover in interface org.springframework.amqp.rabbit.retry.MessageBatchRecoverer

    • recover

      public void recover(org.springframework.amqp.core.Message message, Throwable cause)
      Specified by:
      recover in interface org.springframework.amqp.rabbit.retry.MessageBatchRecoverer
      Specified by:
      recover in interface org.springframework.amqp.rabbit.retry.MessageRecoverer