public class DataflowActivity extends AbstractAsynchronousActivity<com.fasterxml.jackson.databind.JsonNode> implements NestedDataflow
Modifier and Type | Field and Description |
---|---|
static String |
URI |
inputPortMapping, inputPorts, outputPortMapping, outputPorts
Constructor and Description |
---|
DataflowActivity() |
Modifier and Type | Method and Description |
---|---|
void |
configure(com.fasterxml.jackson.databind.JsonNode json)
Called immediately after object construction by the deserialisation
framework with a configuration bean built from the auto-generated XML.
|
void |
executeAsynch(Map<String,T2Reference> data,
AsynchronousActivityCallback callback)
Request an asynchronous invocation of the activity on the specified data.
|
com.fasterxml.jackson.databind.JsonNode |
getConfiguration()
Get a configuration bean representing the definition of the activity.
|
Dataflow |
getNestedDataflow() |
void |
setNestedDataflow(Dataflow dataflow) |
addInput, addOutput, addOutput, configurePorts, getEdits, getInputPortMapping, getInputPorts, getOutputPortMapping, getOutputPorts, removeInputs, removeOutputs, setEdits
getAddAnnotationEdit, getAnnotations, getRemoveAnnotationEdit, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getInputPortMapping, getInputPorts, getOutputPortMapping, getOutputPorts, setEdits
getAddAnnotationEdit, getAnnotations, getRemoveAnnotationEdit, setAnnotations
public static final String URI
public void configure(com.fasterxml.jackson.databind.JsonNode json) throws ActivityConfigurationException
AbstractAsynchronousActivity
This method is responsible for the creation of input and output ports, something that is currently done in the constructor of the Taverna 1 Processor class.
configure
in interface Configurable<com.fasterxml.jackson.databind.JsonNode>
configure
in interface Activity<com.fasterxml.jackson.databind.JsonNode>
configure
in class AbstractAsynchronousActivity<com.fasterxml.jackson.databind.JsonNode>
ActivityConfigurationException
Activity.configure(java.lang.Object)
public com.fasterxml.jackson.databind.JsonNode getConfiguration()
AbstractAsynchronousActivity
getConfiguration
in interface Configurable<com.fasterxml.jackson.databind.JsonNode>
getConfiguration
in class AbstractAsynchronousActivity<com.fasterxml.jackson.databind.JsonNode>
Configurable.getConfiguration()
public void executeAsynch(Map<String,T2Reference> data, AsynchronousActivityCallback callback)
AbstractAsynchronousActivity
This method must not block! However it happens this method must return immediately after creating the new activity invocation. Do not do any heavy lifting in the body of this method without creating a new thread specifically for it.
executeAsynch
in interface AsynchronousActivity<com.fasterxml.jackson.databind.JsonNode>
executeAsynch
in class AbstractAsynchronousActivity<com.fasterxml.jackson.databind.JsonNode>
public Dataflow getNestedDataflow()
getNestedDataflow
in interface NestedDataflow
public void setNestedDataflow(Dataflow dataflow)
setNestedDataflow
in interface NestedDataflow
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.