com.yomahub.liteflow.core

Class NodeComponent

java.lang.Object

com.yomahub.liteflow.core.NodeComponent

Direct Known Subclasses:

NodeBooleanComponent, NodeForComponent, NodeIteratorComponent, NodeSwitchComponent, ScriptCommonComponent

public abstract class NodeComponent
extends Object

普通组件抽象类

Author:

Bryan.Zhang, luo yi, Jay li

Constructor Summary

Constructors

Constructor and Description
NodeComponent()

Method Summary

Modifier and Type	Method and Description
void	afterProcess()
void	beforeProcess()
void	doRollback()
void	execute()
<T> T	getBindData(String key, Class<T> clazz)
<T> List<T>	getBindDataList(String key, Class<T> clazz)
String	getChainId()
String	getChainName() Deprecated. 请使用 getChainId()
<T> T	getCmpData(Class<T> clazz)
<T> List<T>	getCmpDataList(Class<T> clazz)
<T> T	getContextBean(Class<T> contextBeanClazz)
<T> T	getContextBean(String contextName)
<T> T	getContextValue(String expression)
String	getCurrChainId()
long	getCurrChainRuntimeId()
<T> T	getCurrLoopObj()
String	getDisplayName()
<T> T	getFirstContextBean()
<T> T	getItemResultMetaValue(Integer slotIndex)
Integer	getLoopIndex()
protected String	getMetaValueKey()
MonitorBus	getMonitorBus()
String	getName()
Class<? extends NodeExecutor>	getNodeExecutorClass()
String	getNodeId()
Integer	getPreLoopIndex()
<T> T	getPreLoopObj()
Integer	getPreNLoopIndex(int n)
<T> T	getPreNLoopObj(int n)
<T> T	getPrivateDeliveryData()
Node	getRefNode()
<T> T	getRequestData()
int	getRetryCount()
Class<? extends Exception>[]	getRetryForExceptions()
NodeComponent	getSelf()
Slot	getSlot()
Integer	getSlotIndex()
String	getTag()
NodeTypeEnum	getType()
LiteflowResponse	invoke2Resp(String chainId, Object requestData)
LiteflowResponse	invoke2Resp(String chainId, Object requestData, Slot slot)
boolean	isAccess()
boolean	isContinueOnError()
boolean	isEnd()
boolean	isRollback()
void	onError(Exception e)
void	onSuccess()
abstract void	process()
void	removeRefNode()
void	rollback()
<T> void	sendPrivateDeliveryData(String nodeId, T t)
void	setContextValue(String methodExpress, Object... values)
void	setIsContinueOnError(boolean isContinueOnError)
void	setIsEnd(boolean isEnd)
void	setMonitorBus(MonitorBus monitorBus)
void	setName(String name)
void	setNodeExecutorClass(Class<? extends NodeExecutor> nodeExecutorClass)
void	setNodeId(String nodeId)
void	setRefNode(Node refNode)
void	setRetryCount(int retryCount)
void	setRetryForExceptions(Class<? extends Exception>[] retryForExceptions)
void	setRollback(boolean rollback)
void	setSelf(NodeComponent self)
void	setStepData(Object stepData)
void	setType(NodeTypeEnum type)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NodeComponent

public NodeComponent()

Method Detail

execute

public void execute()
             throws Exception

Throws:

Exception

doRollback

public void doRollback()
                throws Exception

Throws:

Exception

beforeProcess

public void beforeProcess()

process

public abstract void process()
                      throws Exception

Throws:

Exception

rollback

public void rollback()
              throws Exception

Throws:

Exception

onSuccess

public void onSuccess()
               throws Exception

Throws:

Exception

onError

public void onError(Exception e)
             throws Exception

Throws:

Exception

afterProcess

public void afterProcess()

isAccess

public boolean isAccess()

isContinueOnError

public boolean isContinueOnError()

isEnd

public boolean isEnd()

setIsEnd

public void setIsEnd(boolean isEnd)

setIsContinueOnError

public void setIsContinueOnError(boolean isContinueOnError)

getSlotIndex

public Integer getSlotIndex()

getSlot

public Slot getSlot()

getFirstContextBean

public <T> T getFirstContextBean()

getContextBean

public <T> T getContextBean(Class<T> contextBeanClazz)

getContextBean

public <T> T getContextBean(String contextName)

getNodeId

public String getNodeId()

setNodeId

public void setNodeId(String nodeId)

getSelf

public NodeComponent getSelf()

setSelf

public void setSelf(NodeComponent self)

getName

public String getName()

setName

public void setName(String name)

getType

public NodeTypeEnum getType()

setType

public void setType(NodeTypeEnum type)

sendPrivateDeliveryData

public <T> void sendPrivateDeliveryData(String nodeId,
                                        T t)

getPrivateDeliveryData

public <T> T getPrivateDeliveryData()

getRetryCount

public int getRetryCount()

setRetryCount

public void setRetryCount(int retryCount)

getRetryForExceptions

public Class<? extends Exception>[] getRetryForExceptions()

setRetryForExceptions

public void setRetryForExceptions(Class<? extends Exception>[] retryForExceptions)

getNodeExecutorClass

public Class<? extends NodeExecutor> getNodeExecutorClass()

setNodeExecutorClass

public void setNodeExecutorClass(Class<? extends NodeExecutor> nodeExecutorClass)

getTag

public String getTag()

getMonitorBus

public MonitorBus getMonitorBus()

setMonitorBus

public void setMonitorBus(MonitorBus monitorBus)

getRequestData

public <T> T getRequestData()

isRollback

public boolean isRollback()

setRollback

public void setRollback(boolean rollback)

getChainName

@Deprecated
public String getChainName()

Deprecated. 请使用 getChainId()

Returns:

String

getChainId

public String getChainId()

getDisplayName

public String getDisplayName()

getCurrChainId

public String getCurrChainId()

getRefNode

public Node getRefNode()

setRefNode

public void setRefNode(Node refNode)

removeRefNode

public void removeRefNode()

getCmpData

public <T> T getCmpData(Class<T> clazz)

Type Parameters:

T - data的泛型

Parameters:

clazz - 要转换的class类型

Returns:

data对象

getCmpDataList

public <T> List<T> getCmpDataList(Class<T> clazz)

getBindData

public <T> T getBindData(String key,
                         Class<T> clazz)

getBindDataList

public <T> List<T> getBindDataList(String key,
                                   Class<T> clazz)

getContextValue

public <T> T getContextValue(String expression)

setContextValue

public void setContextValue(String methodExpress,
                            Object... values)

getLoopIndex

public Integer getLoopIndex()

getPreLoopIndex

public Integer getPreLoopIndex()

getPreNLoopIndex

public Integer getPreNLoopIndex(int n)

getCurrLoopObj

public <T> T getCurrLoopObj()

getPreLoopObj

public <T> T getPreLoopObj()

getPreNLoopObj

public <T> T getPreNLoopObj(int n)

setStepData

public void setStepData(Object stepData)

getItemResultMetaValue

public <T> T getItemResultMetaValue(Integer slotIndex)

getCurrChainRuntimeId

public long getCurrChainRuntimeId()

getMetaValueKey

protected String getMetaValueKey()

invoke2Resp

public LiteflowResponse invoke2Resp(String chainId,
                                    Object requestData)

invoke2Resp

public LiteflowResponse invoke2Resp(String chainId,
                                    Object requestData,
                                    Slot slot)