com.broadleafcommerce.jobsevents.service

Class MasterDeployHeartBeatWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.MasterDeployHeartBeatWorkerImpl

All Implemented Interfaces:

ConsumeWorker, ScheduledDeployManagerAware

@Component(value="blMasterDeployHeartBeatWorker")
 @Scope(value="prototype")
 @Lazy
public class MasterDeployHeartBeatWorkerImpl
extends AbstractConsumerWorker
implements ScheduledDeployManagerAware

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 ScheduledDeployManager	deployManager
protected IncognitoEnvironmentDetector	detector
protected DatabaseSystemEventDao	systemEventDao
protected org.springframework.transaction.PlatformTransactionManager	transactionManager
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
MasterDeployHeartBeatWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
void	init()
void	setScheduledDeployManager(ScheduledDeployManager scheduledDeployManager)

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

deployManager

protected ScheduledDeployManager deployManager

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

systemEventDao

protected DatabaseSystemEventDao systemEventDao

detector

protected IncognitoEnvironmentDetector detector

Constructor Detail

MasterDeployHeartBeatWorkerImpl

public MasterDeployHeartBeatWorkerImpl()

Method Detail

init

@PostConstruct
public void init()

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

Specified by:

execute in interface ConsumeWorker

setScheduledDeployManager

public void setScheduledDeployManager(ScheduledDeployManager scheduledDeployManager)

Specified by:

setScheduledDeployManager in interface ScheduledDeployManagerAware