com.broadleafcommerce.jobsevents.service

Class DeployConsumeWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.DeployConsumeWorkerImpl

All Implemented Interfaces:

ConsumeWorker, ScheduledDeployManagerAware, Stoppable

@Component(value="blDeployConsumeWorker")
 @Scope(value="prototype")
 @Lazy
public class DeployConsumeWorkerImpl
extends AbstractConsumerWorker
implements ScheduledDeployManagerAware, Stoppable

Responsible for retrieving and initiating processing of SystemEvent instances for this node. This worker specifically deals with VM and GLOBAL event types.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected ScheduledDeployManager	deployManager
protected IncognitoEnvironmentDetector	detector
protected int	eventsPerPoll The number of scheduled deploy events to consume per poll from the database
protected DatabaseSystemEventDao	systemEventDao
protected QueueStatusThreadPoolTaskExecutor	taskExecutor
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
DeployConsumeWorkerImpl()

Method Summary

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

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

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

systemEventDao

protected DatabaseSystemEventDao systemEventDao

detector

protected IncognitoEnvironmentDetector detector

deployManager

protected ScheduledDeployManager deployManager

taskExecutor

protected QueueStatusThreadPoolTaskExecutor taskExecutor

eventsPerPoll

@Value(value="${database.deploy.event.quantity.per.poll:20}")
protected int eventsPerPoll

The number of scheduled deploy events to consume per poll from the database

Default property and value: database.deploy.event.quantity.per.poll=20

Constructor Detail

DeployConsumeWorkerImpl

public DeployConsumeWorkerImpl()

Method Detail

init

@PostConstruct
public void init()

stop

public void stop()

Specified by:

stop in interface Stoppable

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

constructTaskExecutor

protected void constructTaskExecutor()