Package | Description |
---|---|
org.apache.taverna.workflowmodel.processor.dispatch |
Definition and support classes for the Dispatch Stack.
|
org.apache.taverna.workflowmodel.processor.dispatch.events | |
org.apache.taverna.workflowmodel.processor.dispatch.layers |
Contains implementations of DispatchLayer defined by the core Taverna 2
specification.
|
Modifier and Type | Field and Description |
---|---|
protected DispatchJobEvent |
AbstractErrorHandlerLayer.JobState.jobEvent |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractErrorHandlerLayer.addJobToStateList(DispatchJobEvent jobEvent) |
protected abstract AbstractErrorHandlerLayer.JobState |
AbstractErrorHandlerLayer.getStateObject(DispatchJobEvent jobEvent)
Generate an appropriate state object from the specified job event.
|
void |
DispatchLayer.receiveJob(DispatchJobEvent jobEvent)
Receive a single job and associated set of activities from the layer
above
|
void |
AbstractErrorHandlerLayer.receiveJob(DispatchJobEvent jobEvent)
Receive a job from the layer above, store it for later retries and pass
it down to the next layer
|
void |
AbstractDispatchLayer.receiveJob(DispatchJobEvent jobEvent) |
Constructor and Description |
---|
JobState(DispatchJobEvent jobEvent) |
Modifier and Type | Method and Description |
---|---|
DispatchJobEvent |
DispatchJobEvent.popOwningProcess() |
DispatchJobEvent |
DispatchJobEvent.pushOwningProcess(String localProcessName) |
Modifier and Type | Field and Description |
---|---|
protected DispatchJobEvent |
Invoke.InvokeCallBack.jobEvent |
Modifier and Type | Method and Description |
---|---|
protected AbstractErrorHandlerLayer.JobState |
Retry.getStateObject(DispatchJobEvent jobEvent) |
protected AbstractErrorHandlerLayer.JobState |
Failover.getStateObject(DispatchJobEvent jobEvent) |
protected void |
Invoke.invoke(DispatchJobEvent jobEvent,
AsynchronousActivity<?> activity) |
void |
Stop.receiveJob(DispatchJobEvent jobEvent) |
void |
Loop.receiveJob(DispatchJobEvent jobEvent) |
void |
Invoke.receiveJob(DispatchJobEvent jobEvent)
Receive a job from the layer above and pick the first concrete activity
from the list to invoke.
|
void |
IntermediateProvenance.receiveJob(DispatchJobEvent jobEvent)
Create the
ProvenanceItem s and send them all across to the
ProvenanceConnector except for the
IterationProvenanceItem , this one is told what it's inputs are
but has to wait until the results are received before being sent across. |
void |
Failover.receiveJob(DispatchJobEvent jobEvent)
Receive a job from the layer above, store it in the state map then relay
it to the layer below with a modified activity list containing only the
activity at index 0
|
void |
ErrorBounce.receiveJob(DispatchJobEvent jobEvent)
If the job contains errors, or collections which contain errors
themselves then bounce a result message with error documents in back up
to the layer above
|
Constructor and Description |
---|
InvokeCallBack(DispatchJobEvent jobEvent,
ReferenceService refService,
String invocationProcessIdentifier,
AsynchronousActivity<?> asyncActivity) |
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.