com.broadleafcommerce.jobsevents.service

Class MasterHeartBeatWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.MasterHeartBeatWorkerImpl

All Implemented Interfaces:

ConsumeWorker

@Service(value="blMasterHearBeatWorker")
public class MasterHeartBeatWorkerImpl
extends AbstractConsumerWorker

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterHeartBeatWorkerImpl.IntervalJob

Field Summary

Fields

Modifier and Type	Field and Description
protected DatabaseSystemEventNode	eventNode
protected ScheduledJobManager	jobManager
protected DatabaseSystemEventDao	systemEventDao
protected List<ScheduledJobThreadInitializer>	threadInitializers
protected org.springframework.transaction.PlatformTransactionManager	transactionManager
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)
void	init()
protected void	manageJobs(org.quartz.Scheduler scheduler, DatabaseSystemEventDao systemEventDao, List<ScheduledJobThreadInitializer> threadInitializers)

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

eventNode

protected DatabaseSystemEventNode eventNode

jobManager

protected ScheduledJobManager jobManager

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

systemEventDao

protected DatabaseSystemEventDao systemEventDao

threadInitializers

protected List<ScheduledJobThreadInitializer> threadInitializers

Constructor Detail

MasterHeartBeatWorkerImpl

public MasterHeartBeatWorkerImpl()

Method Detail

init

@PostConstruct
public void init()

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

manageJobs

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