Package | Description |
---|---|
org.apache.taverna.invocation |
Contains classes supporting workflow invocation.
|
org.apache.taverna.workflowmodel.impl |
Implementation package for workflow entities
|
org.apache.taverna.workflowmodel.processor.activity |
Provides definitions for a single Activity to be contained within a
Processor.
|
org.apache.taverna.workflowmodel.processor.dispatch.events | |
org.apache.taverna.workflowmodel.processor.dispatch.impl |
Implementation package for the dispatch stack interfaces.
|
org.apache.taverna.workflowmodel.processor.iteration.impl |
Implementation logic for the iteration system.
|
Modifier and Type | Class and Description |
---|---|
class |
IterationInternalEvent<EventType extends IterationInternalEvent<?>>
Abstract superclass for event types which have to pass through the iteration
system.
|
Modifier and Type | Class and Description |
---|---|
class |
Completion
Contains a (possibly partial) completion event.
|
Modifier and Type | Method and Description |
---|---|
abstract IterationInternalEvent<EventType> |
IterationInternalEvent.popIndex()
Pop a previously pushed index array off the process name and append the
current index array to create the new index array.
|
abstract IterationInternalEvent<EventType> |
IterationInternalEvent.pushIndex()
Push the index array onto the owning process name and return the new
Event subclass object.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractCrystalizer.receiveEvent(IterationInternalEvent<?> e)
Receive a Job or Completion, Jobs are emitted unaltered and cached,
Completion events trigger registration of a corresponding list - this may
be recursive in nature if the completion event's index implies nested
lists which have not been registered.
|
void |
Crystalizer.receiveEvent(IterationInternalEvent<? extends IterationInternalEvent<?>> event)
Receive a Job or Completion, Jobs are emitted unaltered and cached,
Completion events trigger registration of a corresponding list - this may
be recursive in nature if the completion event's index implies nested
lists which have not been registered.
|
Modifier and Type | Method and Description |
---|---|
void |
Crystalizer.receiveEvent(IterationInternalEvent<? extends IterationInternalEvent<?>> event)
Receive a Job or Completion, Jobs are emitted unaltered and cached,
Completion events trigger registration of a corresponding list - this may
be recursive in nature if the completion event's index implies nested
lists which have not been registered.
|
Modifier and Type | Class and Description |
---|---|
class |
Job
Contains a (possibly partial) job description.
|
Modifier and Type | Method and Description |
---|---|
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> |
DispatchJobQueueEvent.getQueue() |
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> |
DispatchJobQueueEvent.getQueue() |
Constructor and Description |
---|
DispatchJobQueueEvent(String owner,
InvocationContext context,
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> queue,
List<? extends Activity<?>> activities)
Create a new job queue event, specifying the queue of Completion and Job
objects and the list of activities which will be used to process the
corresponding dispatch events
|
DispatchJobQueueEvent(String owner,
InvocationContext context,
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> queue,
List<? extends Activity<?>> activities)
Create a new job queue event, specifying the queue of Completion and Job
objects and the list of activities which will be used to process the
corresponding dispatch events
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
DispatchStackImpl.pushEvent(IterationInternalEvent<? extends IterationInternalEvent<?>> e)
Called when an event (Completion or Job) hits the top of the dispatch
stack and needs to be pushed out of the processor
|
void |
DispatchStackImpl.receiveEvent(IterationInternalEvent event)
Receive an event to be fed into the top layer of the dispatch stack for
processing.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
DispatchStackImpl.pushEvent(IterationInternalEvent<? extends IterationInternalEvent<?>> e)
Called when an event (Completion or Job) hits the top of the dispatch
stack and needs to be pushed out of the processor
|
Modifier and Type | Method and Description |
---|---|
protected void |
IterationStrategyImpl.receiveEvent(IterationInternalEvent<?> e)
Receive a single job from an upstream IterationStrategyImpl in the stack.
|
protected void |
IterationStrategyStackImpl.receiveEventFromStrategy(IterationInternalEvent<? extends IterationInternalEvent<?>> e)
Called by the final iteration strategy to push events onto the
dispatcher's queue
|
Modifier and Type | Method and Description |
---|---|
protected void |
IterationStrategyStackImpl.receiveEventFromStrategy(IterationInternalEvent<? extends IterationInternalEvent<?>> e)
Called by the final iteration strategy to push events onto the
dispatcher's queue
|
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.