com.broadleafcommerce.jobsevents.service

Class MasterIntervalJobWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.MasterIntervalJobWorkerImpl

All Implemented Interfaces:

ConsumeWorker, ScheduledJobManagerAware

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

As part of the work performed in MasterHeartBeatWorkerImpl, job management can result in new Quartz jobs being introduced. Those new jobs are tied to this worker for their execution.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected IncognitoEnvironmentDetector	detector
protected ScheduledJobManager	jobManager
protected com.broadleafcommerce.process.manager.ProcessActionManager	processActionManager
protected com.broadleafcommerce.process.execution.ProcessExecutionManager	processExecutionManager
protected ScheduledJobProcessRegistrationHelper	processRegistrationHelper
protected ScheduledJobEventSender	scheduledJobEventSender
protected SystemEventSender	systemEventSender
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
MasterIntervalJobWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
void	setScheduledJobManager(ScheduledJobManager scheduledJobManager)
protected boolean	shouldExecuteWithProcess(ScheduledJob job)
protected void	startProcess(Long processId)

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

processExecutionManager

protected com.broadleafcommerce.process.execution.ProcessExecutionManager processExecutionManager

processRegistrationHelper

protected ScheduledJobProcessRegistrationHelper processRegistrationHelper

processActionManager

protected com.broadleafcommerce.process.manager.ProcessActionManager processActionManager

scheduledJobEventSender

protected ScheduledJobEventSender scheduledJobEventSender

systemEventSender

protected SystemEventSender systemEventSender

detector

protected IncognitoEnvironmentDetector detector

Constructor Detail

MasterIntervalJobWorkerImpl

public MasterIntervalJobWorkerImpl()

Method Detail

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

Specified by:

execute in interface ConsumeWorker

shouldExecuteWithProcess

protected boolean shouldExecuteWithProcess(ScheduledJob job)

startProcess

protected void startProcess(Long processId)

setScheduledJobManager

public void setScheduledJobManager(ScheduledJobManager scheduledJobManager)

Specified by:

setScheduledJobManager in interface ScheduledJobManagerAware