org.alfresco.bm.process

Class ScheduleProcesses

java.lang.Object

org.alfresco.bm.event.AbstractEventProcessor

org.alfresco.bm.process.ScheduleProcesses

All Implemented Interfaces:

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

public class ScheduleProcesses
extends org.alfresco.bm.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
static String	EVENT_NAME_SCHEDULE_PROCESSES

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

DEFAULT_CHART, DEFAULT_WARN_DELAY, logger

Constructor Summary

Constructors

Constructor and Description
ScheduleProcesses(org.springframework.data.mongodb.core.MongoTemplate mongo, String processData, long timeBetweenProcesses)

Method Summary

Methods

Modifier and Type	Method and Description
org.alfresco.bm.event.EventResult	processEvent(org.alfresco.bm.event.Event event)
void	setEventNameProcess(String eventNameProcess) Override the default event name to process an event

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

getWarnDelay, isChart, register, setBeanName, setChart, setEventName, setEventNames, setRegistry, setWarnDelay

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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

EVENT_NAME_SCHEDULE_PROCESSES

public static final String EVENT_NAME_SCHEDULE_PROCESSES

See Also:

Constant Field Values

Constructor Detail

ScheduleProcesses

public ScheduleProcesses(org.springframework.data.mongodb.core.MongoTemplate mongo,
                 String processData,
                 long timeBetweenProcesses)

Parameters:

mongo - connection to MongoDB

processData - name of DB collection containing process details

processCount - total number of processes to schedule

timeBetweenProcesses - how long between each process

Method Detail

setEventNameProcess

public void setEventNameProcess(String eventNameProcess)

Override the default event name to process an event

processEvent

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

Throws:

Exception