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 java.util.List<Scope> |
incomingScopes |
protected java.util.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() |
java.util.Set<java.lang.String> |
getBranchNames() |
FlowElement |
getFlowElement() |
java.util.List<Scope> |
getIncomingScopes() |
java.util.List<Scope> |
getOutgoingScopes() |
protected void |
handleException(java.lang.Throwable exception,
TupleEntry tupleEntry) |
protected void |
handleReThrowableException(java.lang.String message,
java.lang.Throwable throwable) |
boolean |
hasTrapHandler() |
void |
initialize()
Called immediately after bind
|
void |
setBranchNames(java.util.Set<java.lang.String> branchNames) |
void |
setTrapHandler(TrapHandler trapHandler) |
bind, cleanup, complete, getNext, getNextFor, prepare, receiveFirst, start, toString
protected final FlowProcess flowProcess
protected final java.util.List<Scope> incomingScopes
protected final java.util.List<Scope> outgoingScopes
public BoundaryStage(FlowProcess flowProcess, Boundary boundary)
public BoundaryStage(FlowProcess flowProcess, Boundary boundary, IORole role)
public Boundary getBoundary()
protected void handleReThrowableException(java.lang.String message, java.lang.Throwable throwable)
protected void handleException(java.lang.Throwable exception, TupleEntry tupleEntry)
public void initialize()
Duct
initialize
in class Duct<Incoming,Outgoing>
public void setBranchNames(java.util.Set<java.lang.String> branchNames)
setBranchNames
in interface ElementDuct
public java.util.Set<java.lang.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 java.util.List<Scope> getOutgoingScopes()
getOutgoingScopes
in interface ElementDuct
public java.util.List<Scope> getIncomingScopes()
getIncomingScopes
in interface ElementDuct
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.