public class Stop extends AbstractDispatchLayer<com.fasterxml.jackson.databind.JsonNode>
Modifier and Type | Field and Description |
---|---|
static String |
URI |
CLEANUP_DELAY_MS, cleanupTimer, dispatchStack
Constructor and Description |
---|
Stop() |
Modifier and Type | Method and Description |
---|---|
static boolean |
cancelWorkflow(String workflowRunId)
Cancel the workflow run with the specified id
|
void |
configure(com.fasterxml.jackson.databind.JsonNode conf)
When the item is built from the workflow definition XML the object is
first constructed with a default constructor then this method is called,
passing in the configuration bean returned by getConfiguration().
|
com.fasterxml.jackson.databind.JsonNode |
getConfiguration()
Each item stores configuration within a bean of type ConfigurationType,
this method returns the configuration.
|
static boolean |
pauseWorkflow(String workflowRunId)
Pause the workflow run with the specified id
|
void |
receiveJob(DispatchJobEvent jobEvent)
Receive a single job and associated set of activities from the layer
above
|
void |
receiveJobQueue(DispatchJobQueueEvent jobQueueEvent)
Receive a pointer to the job queue along with a set of activities, this
is received from the layer above in the dispatch stack or from the
DispatchStackImpl object itself if this is the top layer.
|
static boolean |
resumeWorkflow(String workflowRunId)
Resume the workflow run with the specified id
|
finishedWith, getAbove, getBelow, getProcessor, receiveError, receiveResult, receiveResultCompletion, setDispatchStack
public static final String URI
public void configure(com.fasterxml.jackson.databind.JsonNode conf) throws ConfigurationException
Configurable
ConfigurationException
- if a problem occurs when configuring the itempublic com.fasterxml.jackson.databind.JsonNode getConfiguration()
Configurable
public void receiveJob(DispatchJobEvent jobEvent)
DispatchLayer
receiveJob
in interface DispatchLayer<com.fasterxml.jackson.databind.JsonNode>
receiveJob
in class AbstractDispatchLayer<com.fasterxml.jackson.databind.JsonNode>
public void receiveJobQueue(DispatchJobQueueEvent jobQueueEvent)
DispatchLayer
receiveJobQueue
in interface DispatchLayer<com.fasterxml.jackson.databind.JsonNode>
receiveJobQueue
in class AbstractDispatchLayer<com.fasterxml.jackson.databind.JsonNode>
public static boolean cancelWorkflow(String workflowRunId)
workflowRunId
- The id of the workflow run to cancelpublic static boolean pauseWorkflow(String workflowRunId)
workflowRunId
- The id of the workflow run to pausepublic static boolean resumeWorkflow(String workflowRunId)
workflowRunId
- The id of the workflow run to resumeCopyright © 2015–2016 The Apache Software Foundation. All rights reserved.