public abstract class ElementStage<Incoming,Outgoing> extends Stage<Incoming,Outgoing> implements ElementDuct
Modifier and Type | Field and Description |
---|---|
protected Set<String> |
branchNames |
protected FlowElement |
flowElement |
protected FlowProcess |
flowProcess |
protected List<Scope> |
incomingScopes |
protected List<Scope> |
outgoingScopes |
protected TrapHandler |
trapHandler |
Constructor and Description |
---|
ElementStage(FlowProcess flowProcess,
FlowElement flowElement) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
boolean |
equals(Object object) |
Set<String> |
getBranchNames() |
FlowElement |
getFlowElement() |
List<Scope> |
getIncomingScopes() |
protected Fields |
getOutgoingFields() |
List<Scope> |
getOutgoingScopes() |
protected void |
handleException(Throwable exception,
TupleEntry tupleEntry) |
protected void |
handleReThrowableException(String message,
Throwable throwable) |
int |
hashCode() |
boolean |
hasTrapHandler() |
void |
setBranchNames(Set<String> branchNames) |
void |
setTrapHandler(TrapHandler trapHandler) |
String |
toString() |
bind, complete, getNext, getNextFor, initialize, prepare, receiveFirst, start
protected final FlowProcess flowProcess
protected final FlowElement flowElement
protected Set<String> branchNames
protected TrapHandler trapHandler
protected final List<Scope> incomingScopes
protected final List<Scope> outgoingScopes
public ElementStage(FlowProcess flowProcess, FlowElement flowElement)
public FlowElement getFlowElement()
getFlowElement
in interface ElementDuct
public List<Scope> getIncomingScopes()
getIncomingScopes
in interface ElementDuct
public Set<String> getBranchNames()
getBranchNames
in interface ElementDuct
public void setBranchNames(Set<String> branchNames)
setBranchNames
in interface ElementDuct
public void setTrapHandler(TrapHandler trapHandler)
setTrapHandler
in interface ElementDuct
public boolean hasTrapHandler()
hasTrapHandler
in interface ElementDuct
public List<Scope> getOutgoingScopes()
getOutgoingScopes
in interface ElementDuct
protected Fields getOutgoingFields()
protected void handleReThrowableException(String message, Throwable throwable)
protected void handleException(Throwable exception, TupleEntry tupleEntry)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.