Package com.broadleafcommerce.common.messaging.notification

Class DefaultRetryClusterService

java.lang.Object

com.broadleafcommerce.common.messaging.notification.DefaultRetryClusterService

All Implemented Interfaces:

RetryClusterService, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class DefaultRetryClusterService
extends Object
implements RetryClusterService, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.SmartLifecycle

Author:

Jeff Fischer

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
DefaultRetryClusterService(List<NotificationStateRepository> repositories, NotificationHandler notificationHandler, DurableNotificationProperties properties, String messageType, List<IgnoredNotificationStateRepository> ignoredRepositories, com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Summary

Modifier and Type	Method	Description
protected RetryHandler	buildRetryHandler(NotificationStateRepository repository)
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
boolean	isStarted()	Whether a node on the cluster has already been started as a leader.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	start()	Start the node as a leader in the cluster.
void	stop()	Stop the node as a leader in the cluster.
void	stop(Runnable callback)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRetryClusterService

public DefaultRetryClusterService(List<NotificationStateRepository> repositories,
                                  NotificationHandler notificationHandler,
                                  DurableNotificationProperties properties,
                                  String messageType,
                                  List<IgnoredNotificationStateRepository> ignoredRepositories,
                                  com.broadleafcommerce.common.extension.data.DataRouteReference reference)

Method Detail

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

Specified by:

getPhase in interface org.springframework.context.SmartLifecycle

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

start

public void start()

Description copied from interface: RetryClusterService

Start the node as a leader in the cluster.

Specified by:

start in interface org.springframework.context.Lifecycle

Specified by:

start in interface RetryClusterService

isStarted

public boolean isStarted()

Description copied from interface: RetryClusterService

Whether a node on the cluster has already been started as a leader.

Specified by:

isStarted in interface RetryClusterService

Returns:

Whether a node on the cluster has already been started as a leader.

stop

public void stop()

Description copied from interface: RetryClusterService

Stop the node as a leader in the cluster.

Specified by:

stop in interface org.springframework.context.Lifecycle

Specified by:

stop in interface RetryClusterService

buildRetryHandler

protected RetryHandler buildRetryHandler(NotificationStateRepository repository)