Package com.broadleafcommerce.common.messaging.notification

Class DefaultRetryHandler

java.lang.Object

com.broadleafcommerce.common.messaging.notification.DefaultRetryHandler

All Implemented Interfaces:

RetryHandler

public class DefaultRetryHandler
extends Object
implements RetryHandler

Author:

Jeff Fischer

Constructor Summary

Constructors

Constructor	Description
DefaultRetryHandler(NotificationStateRepository repository, NotificationHandler notificationHandler, DurableNotificationProperties properties, String messageType, RoundRobinRetryScheduler scheduler, com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Summary

Modifier and Type	Method	Description
void	addConsumers(List<Consumer<RetryHandlerStatus>> consumers)	Register a list of consumers of retry handler lifecycle events.
void	execute()	Perform the retry processing logic
void	start()	Commence the scheduled processing via a new thread
void	stop()	Stop scheduled processing and exit the processing thread

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultRetryHandler

public DefaultRetryHandler(NotificationStateRepository repository,
 NotificationHandler notificationHandler,
 DurableNotificationProperties properties,
 String messageType,
 RoundRobinRetryScheduler scheduler,
 com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Details

addConsumers

public void addConsumers(List<Consumer<RetryHandlerStatus>> consumers)

Description copied from interface: RetryHandler

Register a list of consumers of retry handler lifecycle events.

Specified by:

addConsumers in interface RetryHandler

Parameters:

consumers - Consumers of retry handler lifecycle events

start

public void start()

Description copied from interface: RetryHandler

Commence the scheduled processing via a new thread

Specified by:

start in interface RetryHandler

stop

public void stop()

Description copied from interface: RetryHandler

Stop scheduled processing and exit the processing thread

Specified by:

stop in interface RetryHandler

execute

public void execute()

Description copied from interface: RetryHandler

Perform the retry processing logic

Specified by:

execute in interface RetryHandler