com.broadleafcommerce.jobsevents.service

Class DurableConsumeWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.DurableConsumeWorkerImpl

All Implemented Interfaces:

ConsumeWorker, DatabaseSystemEventNodeAware, Stoppable

@Component(value="blDurableConsumeWorker")
 @Scope(value="prototype")
 @Lazy
public class DurableConsumeWorkerImpl
extends AbstractConsumerWorker
implements Stoppable, DatabaseSystemEventNodeAware

Responsible for retrieving and initiating processing of SystemEvent instances for this node. This worker specifically deals with GLOBAL_DURABLE event type.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected DatabaseSystemEventNode	eventNode
protected DurableEventStatusService	statusService
protected DatabaseSystemEventDao	systemEventDao
protected QueueStatusThreadPoolTaskExecutor	taskExecutor
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
DurableConsumeWorkerImpl()

Method Summary

Modifier and Type	Method and Description
protected void	constructTaskExecutor()
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
void	setDatabaseSystemEventNode(DatabaseSystemEventNode node)
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

eventNode

protected DatabaseSystemEventNode eventNode

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

systemEventDao

protected DatabaseSystemEventDao systemEventDao

statusService

protected DurableEventStatusService statusService

taskExecutor

protected QueueStatusThreadPoolTaskExecutor taskExecutor

Constructor Detail

DurableConsumeWorkerImpl

public DurableConsumeWorkerImpl()

Method Detail

stop

public void stop()

Specified by:

stop in interface Stoppable

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

Specified by:

execute in interface ConsumeWorker

setDatabaseSystemEventNode

public void setDatabaseSystemEventNode(DatabaseSystemEventNode node)

Specified by:

setDatabaseSystemEventNode in interface DatabaseSystemEventNodeAware

constructTaskExecutor

protected void constructTaskExecutor()