@DispatchLayerJobReaction(emits={ERROR,RESULT_COMPLETION,RESULT}, relaysUnmodified=false, stateEffects={}) @ControlBoundary public class Invoke extends AbstractDispatchLayer<com.fasterxml.jackson.databind.JsonNode>
This layer will invoke the first invokable activity in the activity list, so any sane dispatch stack will have narrowed this down to a single item list by this point, i.e. by the insertion of a failover layer.
Currently only handles activities implementing AsynchronousActivity
.
Modifier and Type | Class and Description |
---|---|
protected class |
Invoke.InvokeCallBack |
Modifier and Type | Field and Description |
---|---|
static String |
URI |
CLEANUP_DELAY_MS, cleanupTimer, dispatchStack
Constructor and Description |
---|
Invoke() |
Modifier and Type | Method and Description |
---|---|
void |
configure(com.fasterxml.jackson.databind.JsonNode config)
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().
|
protected IntermediateProvenance |
findIntermediateProvenance() |
com.fasterxml.jackson.databind.JsonNode |
getConfiguration()
Each item stores configuration within a bean of type ConfigurationType,
this method returns the configuration.
|
protected void |
invoke(DispatchJobEvent jobEvent,
AsynchronousActivity<?> activity) |
void |
receiveJob(DispatchJobEvent jobEvent)
Receive a job from the layer above and pick the first concrete activity
from the list to invoke.
|
finishedWith, getAbove, getBelow, getProcessor, receiveError, receiveJobQueue, receiveResult, receiveResultCompletion, setDispatchStack
public static final String URI
public void configure(com.fasterxml.jackson.databind.JsonNode config)
Configurable
public com.fasterxml.jackson.databind.JsonNode getConfiguration()
Configurable
public void receiveJob(DispatchJobEvent jobEvent)
This layer will invoke the first invokable activity in the activity list, so any sane dispatch stack will have narrowed this down to a single item list by this point, i.e. by the insertion of a failover layer.
receiveJob
in interface DispatchLayer<com.fasterxml.jackson.databind.JsonNode>
receiveJob
in class AbstractDispatchLayer<com.fasterxml.jackson.databind.JsonNode>
protected void invoke(DispatchJobEvent jobEvent, AsynchronousActivity<?> activity)
protected IntermediateProvenance findIntermediateProvenance()
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.