com.broadleafcommerce.jobsevents.service

Class MasterPurgeWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.MasterPurgeWorkerImpl

All Implemented Interfaces:

ConsumeWorker, ScheduledJobManagerAware

@Component(value="blMasterPurgeWorker")
 @Scope(value="prototype")
 @Lazy
public class MasterPurgeWorkerImpl
extends AbstractConsumerWorker
implements ScheduledJobManagerAware

Worker responsible for removing unresponsive master nodes.

Author:

Jeff Fischer

See Also:

ScheduledJobManager

Field Summary

Fields

Modifier and Type	Field and Description
protected IncognitoEnvironmentDetector	detector
protected ScheduledJobManager	jobManager
protected DatabaseSystemEventDao	systemEventDao
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
MasterPurgeWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
protected boolean	isNodeStateWithinTolerance(RegisteredNode node)
protected void	manageMasterNode(Long[] masterUpdatedTime)
protected void	manageRegisteredNodes(Long masterUpdatedTime)
void	setScheduledJobManager(ScheduledJobManager scheduledJobManager)

Methods inherited from class com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

populateSystemEvents

Methods inherited from class java.lang.Object

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

Field Detail

jobManager

protected ScheduledJobManager jobManager

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

systemEventDao

protected DatabaseSystemEventDao systemEventDao

detector

protected IncognitoEnvironmentDetector detector

Constructor Detail

MasterPurgeWorkerImpl

public MasterPurgeWorkerImpl()

Method Detail

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

Specified by:

execute in interface ConsumeWorker

setScheduledJobManager

public void setScheduledJobManager(ScheduledJobManager scheduledJobManager)

Specified by:

setScheduledJobManager in interface ScheduledJobManagerAware

manageRegisteredNodes

protected void manageRegisteredNodes(Long masterUpdatedTime)

manageMasterNode

protected void manageMasterNode(Long[] masterUpdatedTime)

isNodeStateWithinTolerance

protected boolean isNodeStateWithinTolerance(RegisteredNode node)