@Component(value="blPriorityConsumeWorker") @Scope(value="prototype") @Lazy public class PriorityConsumeWorkerImpl extends ConsumeWorkerImpl
SystemEvent instances
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.eventNode, systemEventDao, taskExecutor, transactionManager, transUtil| Constructor and Description |
|---|
PriorityConsumeWorkerImpl() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
constructTaskExecutor() |
protected Long |
getEventsPerPoll() |
protected List<SystemEvent> |
getSystemEvents(int startPos,
Date lowDate,
EventWorkerType workerType) |
execute, getQueuedEventIds, init, setDatabaseSystemEventNode, stoppopulateSystemEventsprotected Long getEventsPerPoll()
getEventsPerPoll in class ConsumeWorkerImplprotected List<SystemEvent> getSystemEvents(int startPos, Date lowDate, EventWorkerType workerType)
getSystemEvents in class ConsumeWorkerImplprotected void constructTaskExecutor()
constructTaskExecutor in class ConsumeWorkerImplCopyright © 2017. All rights reserved.