public class ResultBarrier extends AbstractEventProcessor
RecordedEvent
s) are
available. If the number is reached, an event is scheduled whose name is equal to the value of the property
'nextEventName'.
ReportService
as data-input.
getNextEventName()
, if not: reschedules same event.DEFAULT_CHART, DEFAULT_PROPAGATE_SESSION_ID, DEFAULT_WARN_DELAY, logger
Constructor and Description |
---|
ResultBarrier(String countEventName,
long expectedCount,
String nextEventName,
ResultService resultService)
Create a new barrier.
|
Modifier and Type | Method and Description |
---|---|
String |
getNextEventName() |
EventResult |
processEvent(Event event)
Process an event.
|
void |
setCheckInterval(long checkInterval)
Set the interval this event is scheduled to check if barrier can be released.
|
void |
setNextEventName(String nextEventName) |
getWarnDelay, isChart, processEvent, propagateSessionId, register, resumeTimer, setBeanName, setChart, setEventName, setEventNames, setPropagateSessionId, setRegistry, setWarnDelay, stopTimer, suspendTimer, toString
public ResultBarrier(String countEventName, long expectedCount, String nextEventName, ResultService resultService)
nextEventName
- name of the event to queue when barrier is released.eventService
- event servicepublic EventResult processEvent(Event event) throws Exception
AbstractEventProcessor
processEvent
in class AbstractEventProcessor
event
- the event (along with associated data)Exception
AbstractEventProcessor.suspendTimer()
,
AbstractEventProcessor.resumeTimer()
,
AbstractEventProcessor.stopTimer()
public void setNextEventName(String nextEventName)
nextEventName
- name of the event to queue when number is reached.public String getNextEventName()
public void setCheckInterval(long checkInterval)
checkInterval
- interval in millisCopyright © 2014. All rights reserved.