org.alfresco.bm.event.selector

Class AbstractEventSelectorProcessor

java.lang.Object

org.alfresco.bm.event.AbstractEventProcessor

org.alfresco.bm.event.selector.AbstractEventSelectorProcessor

All Implemented Interfaces:

EventProcessor, EventDataCreator, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public abstract class AbstractEventSelectorProcessor
extends AbstractEventProcessor
implements EventDataCreator

Event processor that uses an eventSelector to choose the next event.

Since:

1.3

Author:

steveglover

Field Summary

Fields inherited from class org.alfresco.bm.event.AbstractEventProcessor

DEFAULT_CHART, DEFAULT_PROPAGATE_SESSION_ID, DEFAULT_WARN_DELAY, logger

Constructor Summary

Constructors

Constructor and Description
AbstractEventSelectorProcessor(EventSelector eventSelector, SessionService sessionService)

Method Summary

Methods

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)

Methods inherited from class org.alfresco.bm.event.AbstractEventProcessor

getWarnDelay, isChart, processEvent, propagateSessionId, register, resumeTimer, setBeanName, setChart, setEventName, setEventNames, setPropagateSessionId, setRegistry, setWarnDelay, stopTimer, suspendTimer, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.alfresco.bm.event.selector.EventDataCreator

createDataObject

Constructor Detail

AbstractEventSelectorProcessor

public AbstractEventSelectorProcessor(EventSelector eventSelector,
                              SessionService sessionService)

Method Detail

setMaxSessionTime

public void setMaxSessionTime(long maxSessionTime)

setPersistResponse

public void setPersistResponse(boolean persistResponse)

Parameters:

persistResponse - true to persist the entire response including the data or false just to persist the response message

processEventImpl

protected abstract EventProcessorResponse processEventImpl(Event event)
                                                    throws Exception

Throws:

Exception

toJSON

protected String toJSON(Object obj)

getPersistableResponse

protected Object getPersistableResponse(EventProcessorResponse response)

createSessionData

protected PersistedSessionData createSessionData(String sessionId)

getSessionData

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. Override this method to control what is persisted.

Parameters:

sessionId -

Returns:

processEvent

public EventResult processEvent(Event event)
                         throws Exception

Description copied from class: AbstractEventProcessor

Process an event.

NOTE: All errors are treated as terminal i.e. there will be no follow-up events published. The event and result services are provided to allow event processing to be aware of previous and future work. If the service is used to modify queues, the results could be unexpected e.g. clearing the queue will not always mean that no more events will be processed.

Timing: Where required, implementations can manually control the times recorded for event processing.

Specified by:

processEvent in class AbstractEventProcessor

Parameters:

event - the event (along with associated data)

Returns:

the result of the process (includes errors and next events)

Throws:

Exception

See Also:

AbstractEventProcessor.suspendTimer(), AbstractEventProcessor.resumeTimer(), AbstractEventProcessor.stopTimer()