public abstract class AbstractFilteringInputPort extends AbstractEventHandlingInputPort implements FilteringInputPort
depth, name
Modifier | Constructor and Description |
---|---|
protected |
AbstractFilteringInputPort(String name,
int depth) |
Modifier and Type | Method and Description |
---|---|
int |
getFilterDepth()
Set the depth at which to filter events.
|
protected abstract void |
pushCompletion(String portName,
String owningProcess,
int[] index,
InvocationContext context)
Action to take when the filter pushes a completion event out
|
protected abstract void |
pushData(String portName,
String owningProcess,
int[] index,
T2Reference data,
InvocationContext context)
Action to take when a data event is created by the filter
|
void |
pushToken(WorkflowDataToken dt,
String owningProcess,
int desiredDepth) |
void |
receiveEvent(WorkflowDataToken token)
Receive an arbitrary workflow event.
|
void |
receiveToken(WorkflowDataToken token) |
void |
setFilterDepth(int filterDepth) |
protected String |
transformOwningProcess(String oldOwner)
Override this to transform owning process identifiers as they pass
through the filter, by default this is the identity transformation
|
getIncomingLink, setIncomingLink, setName
getDepth, getName, toString
getAddAnnotationEdit, getAnnotations, getRemoveAnnotationEdit, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getIncomingLink
getAddAnnotationEdit, getAnnotations, getRemoveAnnotationEdit, setAnnotations
protected AbstractFilteringInputPort(String name, int depth)
public int getFilterDepth()
FilteringInputPort
getFilterDepth
in interface FilteringInputPort
public void receiveEvent(WorkflowDataToken token)
EventHandlingInputPort
receiveEvent
in interface EventHandlingInputPort
public void pushToken(WorkflowDataToken dt, String owningProcess, int desiredDepth)
public void receiveToken(WorkflowDataToken token)
public void setFilterDepth(int filterDepth)
protected abstract void pushCompletion(String portName, String owningProcess, int[] index, InvocationContext context)
portName
- owningProcess
- index
- protected abstract void pushData(String portName, String owningProcess, int[] index, T2Reference data, InvocationContext context)
portName
- owningProcess
- index
- data
- Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.