Package org.nuxeo.ecm.platform.routing.core.impl

Class GraphRunner

java.lang.Object

org.nuxeo.ecm.platform.routing.core.impl.AbstractRunner

org.nuxeo.ecm.platform.routing.core.impl.GraphRunner

All Implemented Interfaces:

Serializable, ElementRunner

public class GraphRunner
extends AbstractRunner
implements ElementRunner, Serializable

Runs the proper nodes depending on the graph state.

Since:

5.6

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_LOOPS	Maximum number of steps we do before deciding that this graph is looping.

Constructor Summary

Constructors

Constructor	Description
GraphRunner()

Method Summary

Modifier and Type	Method	Description
void	cancel(CoreSession session, DocumentRouteElement element)	Cancel this element.
protected void	createTask(CoreSession session, GraphRoute graph, GraphNode node)
protected void	finishTask(CoreSession session, GraphRoute graph, GraphNode node, Task task, boolean delete)
protected void	finishTask(CoreSession session, GraphRoute graph, GraphNode node, Task task, boolean delete, String status)
protected void	recursiveCancelInput(GraphRoute graph, GraphNode originalNode, LinkedList<GraphNode> pendingNodes)
void	resume(CoreSession session, DocumentRouteElement element, String nodeId, String taskId, Map<String,Object> varData, String status)	Resumes this graph route on a given node.
void	run(CoreSession session, DocumentRouteElement element)	Run this element.
void	run(CoreSession session, DocumentRouteElement element, Map<String,Serializable> map)	Run this element.
protected void	runGraph(CoreSession session, DocumentRouteElement element, GraphNode initialNode)	Runs the graph starting with the given node.

Methods inherited from class org.nuxeo.ecm.platform.routing.core.impl.AbstractRunner

getChildrenElement, undo

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.ecm.platform.routing.core.impl.ElementRunner

undo

Field Detail

MAX_LOOPS

public static final int MAX_LOOPS

Maximum number of steps we do before deciding that this graph is looping.

See Also:

Constant Field Values

Constructor Detail

GraphRunner

public GraphRunner()

Method Detail

run

public void run(CoreSession session,
                DocumentRouteElement element,
                Map<String,Serializable> map)

Description copied from interface: ElementRunner

Run this element.

Specified by:

run in interface ElementRunner

Overrides:

run in class AbstractRunner

run

public void run(CoreSession session,
                DocumentRouteElement element)

Description copied from interface: ElementRunner

Run this element. If an exception is thrown while doing, it cancels the route.

Specified by:

run in interface ElementRunner

resume

public void resume(CoreSession session,
                   DocumentRouteElement element,
                   String nodeId,
                   String taskId,
                   Map<String,Object> varData,
                   String status)

Description copied from interface: ElementRunner

Resumes this graph route on a given node.

Specified by:

resume in interface ElementRunner

Overrides:

resume in class AbstractRunner

cancel

public void cancel(CoreSession session,
                   DocumentRouteElement element)

Description copied from interface: ElementRunner

Cancel this element.

Specified by:

cancel in interface ElementRunner

Overrides:

cancel in class AbstractRunner

See Also:

DocumentRouteElement.cancel(CoreSession)

runGraph

protected void runGraph(CoreSession session,
                        DocumentRouteElement element,
                        GraphNode initialNode)
                 throws DocumentRouteException

Runs the graph starting with the given node.

Parameters:

initialNode - the initial node to run

Throws:

DocumentRouteException

recursiveCancelInput

protected void recursiveCancelInput(GraphRoute graph,
                                    GraphNode originalNode,
                                    LinkedList<GraphNode> pendingNodes)

createTask

protected void createTask(CoreSession session,
                          GraphRoute graph,
                          GraphNode node)
                   throws DocumentRouteException

Throws:

DocumentRouteException

finishTask

protected void finishTask(CoreSession session,
                          GraphRoute graph,
                          GraphNode node,
                          Task task,
                          boolean delete)
                   throws DocumentRouteException

Throws:

DocumentRouteException

finishTask

protected void finishTask(CoreSession session,
                          GraphRoute graph,
                          GraphNode node,
                          Task task,
                          boolean delete,
                          String status)
                   throws DocumentRouteException

Throws:

DocumentRouteException