com.broadleafcommerce.jobsevents.service

Class MasterHeartBeatWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.MasterHeartBeatWorkerImpl

All Implemented Interfaces:

ConsumeWorker, ScheduledJobManagerAware

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

This worker is responsible for several duties. One, it maintains the updated date for the master, which is used to determine if a master is still alive and responding. Unresponsive masters are purged, allowing another node to arise to master status (this is a master/slave HA configuration). Second, this worker reviews the current database configuration for ScheduledJob instances and will manage the local Quartz configuration accordingly.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected IncognitoEnvironmentDetector	detector
protected ScheduledJobManager	jobManager
static String	NODENAME
protected DatabaseSystemEventDao	systemEventDao
protected List<ScheduledJobThreadInitializer>	threadInitializers
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
MasterHeartBeatWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
protected void	manageJobs(org.quartz.Scheduler scheduler, DatabaseSystemEventDao systemEventDao, List<ScheduledJobThreadInitializer> threadInitializers)
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

NODENAME

public static final String NODENAME

See Also:

Constant Field Values

jobManager

protected ScheduledJobManager jobManager

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

systemEventDao

protected DatabaseSystemEventDao systemEventDao

threadInitializers

protected List<ScheduledJobThreadInitializer> threadInitializers

detector

protected IncognitoEnvironmentDetector detector

Constructor Detail

MasterHeartBeatWorkerImpl

public MasterHeartBeatWorkerImpl()

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

manageJobs

protected void manageJobs(org.quartz.Scheduler scheduler,
                          DatabaseSystemEventDao systemEventDao,
                          List<ScheduledJobThreadInitializer> threadInitializers)