public class RaiseEventsEventProcessor extends AbstractEventProcessor
setEventNameRaiseEvents(String)
: Self-triggering eventoutputEventName
: Obtains data from getNextEventData()
DEFAULT_CHART, DEFAULT_PROPAGATE_SESSION_ID, DEFAULT_WARN_DELAY, logger
Constructor and Description |
---|
RaiseEventsEventProcessor(String outputEventName,
long timeBetweenEvents,
int outputEventCount)
Constructor with essential values
|
Modifier and Type | Method and Description |
---|---|
protected Object |
getNextEventData()
Get data to provide for each event raised.
|
EventResult |
processEvent(Event event)
Process an event.
|
void |
setBatchSize(int batchSize)
Override the
default batch size |
void |
setEventNameRaiseEvents(String eventNameRaiseEvents)
Override the
default name for repeat batches |
getWarnDelay, isChart, processEvent, propagateSessionId, register, resumeTimer, setBeanName, setChart, setEventName, setEventNames, setPropagateSessionId, setRegistry, setWarnDelay, stopTimer, suspendTimer, toString
public RaiseEventsEventProcessor(String outputEventName, long timeBetweenEvents, int outputEventCount)
outputEventName
- the name of the event to emittimeBetweenEvents
- the time between eventsoutputEventCount
- the number of events to emitpublic void setBatchSize(int batchSize)
default
batch sizepublic void setEventNameRaiseEvents(String eventNameRaiseEvents)
default
name for repeat batchespublic 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()
protected Object getNextEventData()
Copyright © 2014. All rights reserved.