Package com.broadleafcommerce.common.messaging.retry.kafka

Class KafkaNonBlockingRetryConsumer

java.lang.Object
com.broadleafcommerce.common.messaging.retry.BackOffAwareRetryConsumer
com.broadleafcommerce.common.messaging.retry.kafka.KafkaNonBlockingRetryConsumer
All Implemented Interfaces:
Consumer<org.springframework.messaging.Message<?>>
public class KafkaNonBlockingRetryConsumer extends BackOffAwareRetryConsumer implements Consumer<org.springframework.messaging.Message<?>>
Message consumer for a retry binding in the non-blocking case. Non-blocking retry channels perform the simple purpose of waiting the backoff period before sending the message back to the original consumer binding. In this kafka case, the messages are NOT auto acknowledged, and if the backoff interval has not elapsed when inspecting a polled message, the message is nacked and will be checked again during the next poll.

  • Constructor Details

    • KafkaNonBlockingRetryConsumer

      public KafkaNonBlockingRetryConsumer(com.broadleafcommerce.common.extension.compatibility.support.messaging.TimeoutAwareStreamBridge streamBridge, NonBlockingRetryProperties nonBlockingRetryProperties)

  • Method Details

    • accept

      public void accept(org.springframework.messaging.Message<?> message)
      Specified by:
      accept in interface Consumer<org.springframework.messaging.Message<?>>