Package | Description |
---|---|
org.apache.taverna.platform.capability.api | |
org.apache.taverna.platform.capability.dispatch.impl | |
org.apache.taverna.workflowmodel |
Defines classes and interfaces for workflow level entities and events.
|
org.apache.taverna.workflowmodel.impl |
Implementation package for workflow entities
|
org.apache.taverna.workflowmodel.processor.dispatch |
Definition and support classes for the Dispatch Stack.
|
org.apache.taverna.workflowmodel.processor.dispatch.impl |
Implementation package for the dispatch stack interfaces.
|
org.apache.taverna.workflowmodel.processor.dispatch.layers |
Contains implementations of DispatchLayer defined by the core Taverna 2
specification.
|
Modifier and Type | Method and Description |
---|---|
DispatchLayer<?> |
DispatchLayerService.createDispatchLayer(URI uri,
com.fasterxml.jackson.databind.JsonNode configuration)
Returns the dispatch layer for the specified URI.
|
Modifier and Type | Method and Description |
---|---|
DispatchLayer<?> |
DispatchLayerServiceImpl.createDispatchLayer(URI dispatchLayerType,
com.fasterxml.jackson.databind.JsonNode configuration) |
Modifier and Type | Method and Description |
---|---|
Edit<DispatchStack> |
Edits.getAddDispatchLayerEdit(DispatchStack stack,
DispatchLayer<?> layer,
int position)
Add a new layer to the specified dispatch stack
|
Edit<DispatchStack> |
Edits.getDeleteDispatchLayerEdit(DispatchStack stack,
DispatchLayer<?> layer)
Remove a dispatch layer from its dispatch stack
|
Modifier and Type | Method and Description |
---|---|
Edit<DispatchStack> |
EditsImpl.getAddDispatchLayerEdit(DispatchStack stack,
DispatchLayer<?> layer,
int position) |
Edit<DispatchStack> |
EditsImpl.getDeleteDispatchLayerEdit(DispatchStack stack,
DispatchLayer<?> layer) |
Modifier and Type | Interface and Description |
---|---|
interface |
PropertyContributingDispatchLayer<ConfigType>
Used by dispatch layers which can contribute property information to their
parent processor instance.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDispatchLayer<ConfigurationType>
Convenience abstract implementation of DispatchLayer
|
class |
AbstractErrorHandlerLayer<ConfigurationType>
Superclass of error handling dispatch layers (for example retry and
failover).
|
Modifier and Type | Method and Description |
---|---|
DispatchLayer<?> |
DispatchLayerFactory.createDispatchLayer(URI dispatchLayerType)
Creates a new
DispatchLayer instance. |
protected DispatchLayer<?> |
AbstractDispatchLayer.getAbove() |
protected DispatchLayer<?> |
AbstractDispatchLayer.getBelow() |
DispatchLayer<?> |
DispatchStack.layerAbove(DispatchLayer<?> layer)
Return the layer above (lower index!) the specified layer, or a reference
to the internal top layer dispatch layer if there is no layer above the
specified one.
|
DispatchLayer<?> |
DispatchStack.layerBelow(DispatchLayer<?> layer)
Return the layer below (higher index) the specified layer, or null if
there is no layer below this one.
|
Modifier and Type | Method and Description |
---|---|
List<DispatchLayer<?>> |
DispatchStack.getLayers()
The DispatchStack consists of an ordered list of DispatchLayer instances
where the DispatchLayer at index zero is at the bottom of the stack and
is almost always an invocation layer of some kind (in any working
dispatch stack configuration)
|
Modifier and Type | Method and Description |
---|---|
DispatchLayer<?> |
DispatchStack.layerAbove(DispatchLayer<?> layer)
Return the layer above (lower index!) the specified layer, or a reference
to the internal top layer dispatch layer if there is no layer above the
specified one.
|
DispatchLayer<?> |
DispatchStack.layerBelow(DispatchLayer<?> layer)
Return the layer below (higher index) the specified layer, or null if
there is no layer below this one.
|
Modifier and Type | Class and Description |
---|---|
protected class |
DispatchStackImpl.TopLayer |
Modifier and Type | Method and Description |
---|---|
protected DispatchLayer<?> |
DispatchStackImpl.firstLayer() |
DispatchLayer<?> |
DispatchStackImpl.layerAbove(DispatchLayer<?> layer)
Return the layer above (lower index!) the specified layer, or a reference
to the internal top layer dispatch layer if there is no layer above the
specified one.
|
DispatchLayer<?> |
DispatchStackImpl.layerBelow(DispatchLayer<?> layer)
Return the layer below (higher index) the specified layer, or null if
there are no layers below this one
|
Modifier and Type | Method and Description |
---|---|
List<DispatchLayer<?>> |
DispatchStackImpl.getLayers() |
Modifier and Type | Method and Description |
---|---|
void |
DispatchStackImpl.addLayer(DispatchLayer<?> newLayer) |
void |
DispatchStackImpl.addLayer(DispatchLayer<?> newLayer,
int index) |
DispatchLayer<?> |
DispatchStackImpl.layerAbove(DispatchLayer<?> layer)
Return the layer above (lower index!) the specified layer, or a reference
to the internal top layer dispatch layer if there is no layer above the
specified one.
|
DispatchLayer<?> |
DispatchStackImpl.layerBelow(DispatchLayer<?> layer)
Return the layer below (higher index) the specified layer, or null if
there are no layers below this one
|
int |
DispatchStackImpl.removeLayer(DispatchLayer<?> layer) |
Modifier and Type | Class and Description |
---|---|
class |
ErrorBounce
Receives job events, checks to see whether any parameters in the job are
error tokens or collections which contain errors.
|
class |
Failover
Failure handling dispatch layer, consumes job events with multiple activities
and emits the same job but with only the first activity.
|
class |
IntermediateProvenance
Sits above the
Invoke layer and collects information about the
current workflow run to be stored by the ProvenanceConnector . |
class |
Invoke
Context free invoker layer, does not pass index arrays of jobs into activity
instances.
|
class |
Loop
A layer that allows while-style loops.
|
class |
Parallelize
Dispatch layer which consumes a queue of events and fires off a fixed number
of simultaneous jobs to the layer below.
|
class |
Retry
Implements retry policy with delay between retries and exponential backoff
|
class |
Stop
This layer allows for the cancellation, pausing and resuming of workflow
runs.
|
Modifier and Type | Method and Description |
---|---|
DispatchLayer<?> |
CoreDispatchLayerFactory.createDispatchLayer(URI uri) |
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.