public abstract class AbstractEventSelectorProcessor extends AbstractEventProcessor implements EventDataCreator
DEFAULT_CHART, DEFAULT_PROPAGATE_SESSION_ID, DEFAULT_WARN_DELAY, logger
Constructor and Description |
---|
AbstractEventSelectorProcessor(EventSelector eventSelector,
SessionService sessionService) |
Modifier and Type | Method and Description |
---|---|
protected PersistedSessionData |
createSessionData(String sessionId) |
protected Object |
getPersistableResponse(EventProcessorResponse response) |
protected PersistedSessionData |
getSessionData(String sessionId)
Get session data associated with the given sessionId, creating it with the expected minimum session end time if it doesn't exist.
|
EventResult |
processEvent(Event event)
Process an event.
|
protected abstract EventProcessorResponse |
processEventImpl(Event event) |
void |
setMaxSessionTime(long maxSessionTime) |
void |
setPersistResponse(boolean persistResponse) |
protected String |
toJSON(Object obj) |
getWarnDelay, isChart, processEvent, propagateSessionId, register, resumeTimer, setBeanName, setChart, setEventName, setEventNames, setPropagateSessionId, setRegistry, setWarnDelay, stopTimer, suspendTimer, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createDataObject
public AbstractEventSelectorProcessor(EventSelector eventSelector, SessionService sessionService)
public void setMaxSessionTime(long maxSessionTime)
public void setPersistResponse(boolean persistResponse)
persistResponse
- true to persist the entire response including the data
or false just to persist the response messageprotected abstract EventProcessorResponse processEventImpl(Event event) throws Exception
Exception
protected Object getPersistableResponse(EventProcessorResponse response)
protected PersistedSessionData createSessionData(String sessionId)
protected PersistedSessionData getSessionData(String sessionId)
sessionId
- public 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()
Copyright © 2014. All rights reserved.