com.broadleafcommerce.jobsevents.service

Class GlobalConsumeWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.ConsumeWorkerImpl

com.broadleafcommerce.jobsevents.service.GlobalConsumeWorkerImpl

All Implemented Interfaces:

ConsumeWorker, DatabaseSystemEventNodeAware, Stoppable

@Component(value="blGlobalConsumeWorker")
 @Scope(value="prototype")
 @Lazy
public class GlobalConsumeWorkerImpl
extends ConsumeWorkerImpl

Responsible for retrieving and initiating processing of SystemEvent instances of type EventScopeType.GLOBAL for this node. This worker specifically deals with VM and GLOBAL event types. The events processed here are of priority status, meaning the SystemEvent.getPriority() is less than 0.

Priority events are generally considered to be important functional events that consume very quickly (e.g. cache invalidations). Processing these events in their own queue attempts to guarantee a more timely processing, instead of having them queue up with regular, possibly long-running, events in the standard queue.

Author:

Jeff Fischer

Field Summary

Fields inherited from class com.broadleafcommerce.jobsevents.service.ConsumeWorkerImpl

eventNode, systemEventDao, taskExecutor, transUtil

Constructor Summary

Constructors

Constructor and Description
GlobalConsumeWorkerImpl()

Method Summary

Modifier and Type	Method and Description
protected void	constructTaskExecutor()
protected Long	getEventsPerPoll()
protected List<SystemEvent>	getSystemEvents(int startPos, Date lowDate, EventWorkerType workerType)

Methods inherited from class com.broadleafcommerce.jobsevents.service.ConsumeWorkerImpl

execute, getQueuedEventIds, setDatabaseSystemEventNode, 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

Constructor Detail

GlobalConsumeWorkerImpl

public GlobalConsumeWorkerImpl()

Method Detail

getEventsPerPoll

protected Long getEventsPerPoll()

Overrides:

getEventsPerPoll in class ConsumeWorkerImpl

getSystemEvents

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

Overrides:

getSystemEvents in class ConsumeWorkerImpl

constructTaskExecutor

protected void constructTaskExecutor()

Overrides:

constructTaskExecutor in class ConsumeWorkerImpl