public class GraphRunner extends AbstractRunner implements ElementRunner, Serializable
Modifier and Type | Field and Description |
---|---|
static int |
MAX_LOOPS
Maximum number of steps we do before deciding that this graph is looping.
|
Constructor and Description |
---|
GraphRunner() |
Modifier and Type | Method and 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.
|
getChildrenElement, undo
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
undo
public static final int MAX_LOOPS
public GraphRunner()
public void run(CoreSession session, DocumentRouteElement element, Map<String,Serializable> map)
ElementRunner
run
in interface ElementRunner
run
in class AbstractRunner
public void run(CoreSession session, DocumentRouteElement element)
ElementRunner
run
in interface ElementRunner
public void resume(CoreSession session, DocumentRouteElement element, String nodeId, String taskId, Map<String,Object> varData, String status)
ElementRunner
resume
in interface ElementRunner
resume
in class AbstractRunner
public void cancel(CoreSession session, DocumentRouteElement element)
ElementRunner
cancel
in interface ElementRunner
cancel
in class AbstractRunner
DocumentRouteElement.cancel(CoreSession)
protected void runGraph(CoreSession session, DocumentRouteElement element, GraphNode initialNode) throws DocumentRouteException
graph
- the graphinitialNode
- the initial node to runDocumentRouteException
protected void recursiveCancelInput(GraphRoute graph, GraphNode originalNode, LinkedList<GraphNode> pendingNodes)
protected void createTask(CoreSession session, GraphRoute graph, GraphNode node) throws DocumentRouteException
DocumentRouteException
protected void finishTask(CoreSession session, GraphRoute graph, GraphNode node, Task task, boolean delete) throws DocumentRouteException
DocumentRouteException
protected void finishTask(CoreSession session, GraphRoute graph, GraphNode node, Task task, boolean delete, String status) throws DocumentRouteException
DocumentRouteException
Copyright © 2017 Nuxeo. All rights reserved.