Package com.broadleafcommerce.common.messaging.retry.pubsub

Class PubSubDelayedRetryConsumer

java.lang.Object

com.broadleafcommerce.common.messaging.retry.BackOffAwareRetryConsumer

com.broadleafcommerce.common.messaging.retry.pubsub.PubSubDelayedRetryConsumer

All Implemented Interfaces:

Consumer<org.springframework.messaging.Message<?>>

public class PubSubDelayedRetryConsumer
extends BackOffAwareRetryConsumer
implements Consumer<org.springframework.messaging.Message<?>>

Message consumer for a retry binding in Google PubSub. Retry channels perform the simple purpose of waiting the backoff period before sending the message back to the original consumer binding. In this pubsub 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 Summary

Constructors

Constructor	Description
PubSubDelayedRetryConsumer(com.broadleafcommerce.common.extension.compatibility.support.messaging.TimeoutAwareStreamBridge streamBridge)

Method Summary

Modifier and Type	Method	Description
void	accept(org.springframework.messaging.Message<?> message)

Methods inherited from class com.broadleafcommerce.common.messaging.retry.BackOffAwareRetryConsumer

isBackOffSatisfied, resend, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Details

PubSubDelayedRetryConsumer

public PubSubDelayedRetryConsumer(com.broadleafcommerce.common.extension.compatibility.support.messaging.TimeoutAwareStreamBridge streamBridge)

Method Details

accept

public void accept(org.springframework.messaging.Message<?> message)

Specified by:

accept in interface Consumer<org.springframework.messaging.Message<?>>