org.alfresco.bm.wf

Class ScheduleWorkflows

java.lang.Object

org.alfresco.bm.event.AbstractEventProcessor

org.alfresco.bm.wf.ScheduleWorkflows

All Implemented Interfaces:

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

public class ScheduleWorkflows
extends org.alfresco.bm.event.AbstractEventProcessor

Schedule processing events.

Input

No input requirements

Data

A MongoDB collection containing unstarted workflows data.

Actions

The MongoDB collection is examined to find unscheduled workflows. They are scheduled up to a batch size after which this processor reschedules itself.

Output

EVENT_NAME_START_WORKFLOW: the workflow ID
EVENT_NAME_SCHEDULE_WORKFLOWS: The process name
EVENT_NAME_WORKFLOWS_SCHEDULED: 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_SCHEDULE_WORKFLOWS
static String	EVENT_NAME_START_WORKFLOW
static String	EVENT_NAME_WORKFLOWS_SCHEDULED

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

DEFAULT_AUTO_CLOSE_SESSION_ID, DEFAULT_AUTO_PROPAGATE_SESSION_ID, DEFAULT_CHART, DEFAULT_WARN_DELAY, logger

Constructor Summary

Constructors

Constructor and Description
ScheduleWorkflows(WorkflowDAO workflowDAO, long timeBetweenWorkflows)

Method Summary

Modifier and Type	Method and Description
org.alfresco.bm.event.EventResult	processEvent(org.alfresco.bm.event.Event event)
void	setBatchSize(int batchSize) Set the size of the batches the unscheduled workflows will be started in.
void	setEventNameScheduleWorkflows(String eventNameScheduleWorkflows) Override the default event name
void	setEventNameStartWorkflow(String eventNameStartWorkflow) Override the default event name
void	setEventNameWorkflowsScheduled(String eventNameWorkflowsScheduled) Override the default event name

Methods inherited from class org.alfresco.bm.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_START_WORKFLOW

public static final String EVENT_NAME_START_WORKFLOW

See Also:

Constant Field Values

EVENT_NAME_SCHEDULE_WORKFLOWS

public static final String EVENT_NAME_SCHEDULE_WORKFLOWS

See Also:

Constant Field Values

EVENT_NAME_WORKFLOWS_SCHEDULED

public static final String EVENT_NAME_WORKFLOWS_SCHEDULED

See Also:

Constant Field Values

Constructor Detail

ScheduleWorkflows

public ScheduleWorkflows(WorkflowDAO workflowDAO,
                         long timeBetweenWorkflows)

Method Detail

setEventNameStartWorkflow

public void setEventNameStartWorkflow(String eventNameStartWorkflow)

Override the default event name

setEventNameScheduleWorkflows

public void setEventNameScheduleWorkflows(String eventNameScheduleWorkflows)

Override the default event name

setEventNameWorkflowsScheduled

public void setEventNameWorkflowsScheduled(String eventNameWorkflowsScheduled)

Override the default event name

processEvent

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

Specified by:

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

Throws:

Exception

setBatchSize

public void setBatchSize(int batchSize)

Set the size of the batches the unscheduled workflows will be started in.

Parameters:

batchSize - size of a batch