com.broadleafcommerce.jobsevents.service

Class ConsumeWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.ConsumeWorkerImpl

All Implemented Interfaces:

ConsumeWorker, DatabaseSystemEventNodeAware, Stoppable

Direct Known Subclasses:

GlobalConsumeWorkerImpl, PriorityConsumeWorkerImpl

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

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

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected DatabaseSystemEventNode	eventNode
protected DatabaseSystemEventDao	systemEventDao
protected QueueStatusThreadPoolTaskExecutor	taskExecutor
protected org.springframework.transaction.PlatformTransactionManager	transactionManager
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
ConsumeWorkerImpl()

Method Summary

Modifier and Type	Method and Description
protected void	constructTaskExecutor()
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
protected Long	getEventsPerPoll()
protected List<Long>	getQueuedEventIds()
protected List<SystemEvent>	getSystemEvents(int startPos, Date lowDate, EventWorkerType workerType)
void	init()
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

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

systemEventDao

protected DatabaseSystemEventDao systemEventDao

taskExecutor

protected QueueStatusThreadPoolTaskExecutor taskExecutor

Constructor Detail

ConsumeWorkerImpl

public ConsumeWorkerImpl()

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

setDatabaseSystemEventNode

public void setDatabaseSystemEventNode(DatabaseSystemEventNode node)

Specified by:

setDatabaseSystemEventNode in interface DatabaseSystemEventNodeAware

getEventsPerPoll

protected Long getEventsPerPoll()

getQueuedEventIds

protected List<Long> getQueuedEventIds()

getSystemEvents

protected List<SystemEvent> getSystemEvents(int startPos,
                                            Date lowDate,
                                            EventWorkerType workerType)

constructTaskExecutor

protected void constructTaskExecutor()