org.alfresco.bm.process

Class ScheduleProcesses

java.lang.Object

org.alfresco.bm.driver.event.AbstractEventProcessor

org.alfresco.bm.process.ScheduleProcesses

All Implemented Interfaces:

org.alfresco.bm.driver.event.EventProcessor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public class ScheduleProcesses
extends org.alfresco.bm.driver.event.AbstractEventProcessor

Schedule processing events.

Input

No input requirements

Data

A MongoDB collection containing unprocessed data.

Actions

The MongoDB collection is examined to find (see unfinished processes. Unfinished processes are scheduled up to a batch size after which this processor reschedules itself.

Output

EVENT_NAME_PROCESS: The process name
#EVENT_NAME_SCHEDULE_PROCESSES: No data

Since:

1.0

Author:

Derek Hulley

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BATCH_SIZE
static String	EVENT_NAME_PROCESS

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

DEFAULT_AUTO_CLOSE_SESSION_ID, DEFAULT_AUTO_PROPAGATE_SESSION_ID, DEFAULT_CHART, DEFAULT_WARN_DELAY

Constructor Summary

Constructors

Constructor and Description
ScheduleProcesses(org.alfresco.bm.common.session.SessionService sessionService, ProcessDataDAO processDataDAO, String testRunFqn, int processCount, long timeBetweenProcesses)

Method Summary

Modifier and Type	Method and Description
org.alfresco.bm.common.EventResult	processEvent(org.alfresco.bm.driver.event.Event event)
void	setBatchSize(int batchSize) Override the default batch size for event processing
void	setEventNameProcess(String eventNameProcess) Override the default event name to process an event

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

getName, getWarnDelay, isAutoCloseSessionId, isAutoPropagateSessionId, isChart, processEvent, register, resumeTimer, setAutoCloseSessionId, setAutoPropagateSessionId, setBeanName, setChart, setEventName, setEventNames, setRegistry, setWarnDelay, stopTimer, suspendTimer, toString

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

Constant Field Values

EVENT_NAME_PROCESS

public static final String EVENT_NAME_PROCESS

See Also:

Constant Field Values

Constructor Detail

ScheduleProcesses

public ScheduleProcesses(org.alfresco.bm.common.session.SessionService sessionService,
                         ProcessDataDAO processDataDAO,
                         String testRunFqn,
                         int processCount,
                         long timeBetweenProcesses)

Parameters:

sessionService - service to create and manage persisted session data

processDataDAO - the DAO for storing process data

testRunFqn - the name of the test run

processCount - the number of processes to run

timeBetweenProcesses - how long between each process

Method Detail

setEventNameProcess

public void setEventNameProcess(String eventNameProcess)

Override the default event name to process an event

setBatchSize

public void setBatchSize(int batchSize)

Override the default batch size for event processing

processEvent

public org.alfresco.bm.common.EventResult processEvent(org.alfresco.bm.driver.event.Event event)
                                                throws Exception

Specified by:

processEvent in class org.alfresco.bm.driver.event.AbstractEventProcessor

Throws:

Exception