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