com.yomahub.liteflow.slot

Class Slot

java.lang.Object

com.yomahub.liteflow.slot.Slot

public class Slot
extends Object

Slot的抽象类实现

Author:

Bryan.Zhang, LeoLee, DaleLee, Jay li

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentHashMap<String,Object>	metaDataMap

Constructor Summary

Constructors

Constructor and Description
Slot()
Slot(List<cn.hutool.core.lang.Tuple> contextBeanList)

Method Summary

Modifier and Type	Method and Description
void	addChainInstance(Chain chain)
void	addRollbackStep(CmpStep step)
void	addStep(CmpStep step)
void	addTimeoutItem(String executorItem)
void	generateRequestId()
Boolean	getAndOrResult(String key)
Boolean	getBreakResult(String key)
String	getChainId()
String	getChainName() Deprecated. 请使用 getChainId()
<T> T	getChainReqData(String chainId)
<T> T	getChainReqDataFromQueue(String chainId)
<T> T	getContextBean(Class<T> contextBeanClazz)
<T> T	getContextBean(String contextBeanKey)
List<cn.hutool.core.lang.Tuple>	getContextBeanList()
Chain	getCurrentChainInstance(String currentChainId)
Condition	getCurrentCondition()
Exception	getException()
Deque<CmpStep>	getExecuteSteps()
String	getExecuteStepStr()
String	getExecuteStepStr(boolean withTimeSpent)
String	getExecuteStepStrWithInstanceId()
<T> T	getFirstContextBean()
Integer	getForResult(String key)
Boolean	getIfResult(String key)
<T> T	getInput(String nodeId)
Iterator<?>	getIteratorResult(String key)
Boolean	getNotResult(String key)
<T> T	getOutput(String nodeId)
<T> T	getPrivateDeliveryData(String nodeId)
<T> Queue<T>	getPrivateDeliveryQueue(String nodeId)
String	getRequestId()
<T> T	getResponseData()
Deque<CmpStep>	getRollbackSteps()
String	getRollbackStepStr()
String	getRollbackStepStr(boolean withRollbackTimeSpent)
Boolean	getRouteResult()
Exception	getSubException(String chainId)
<T> T	getSwitchResult(String key)
List<String>	getTimeoutItemList()
Boolean	getWhileResult(String key)
void	popCondition()
void	printRollbackStep()
void	printStep()
void	pushCondition(Condition condition)
void	putRequestId(String requestId)
void	removeException()
void	setAndOrResult(String key, boolean result)
void	setBreakResult(String key, boolean breakFlag)
void	setChainId(String chainId)
void	setChainName(String chainName) Deprecated. 请使用 setChainId(String)
<T> void	setChainReqData(String chainId, T t)
<T> void	setChainReqData2Queue(String chainId, T t)
void	setException(Exception e)
void	setForResult(String key, int forCount)
void	setIfResult(String key, boolean result)
<T> void	setInput(String nodeId, T t)
void	setIteratorResult(String key, Iterator<?> it)
void	setNotResult(String key, boolean result)
<T> void	setOutput(String nodeId, T t)
<T> void	setPrivateDeliveryData(String nodeId, T t)
<T> void	setResponseData(T t)
void	setRouteResult(Boolean routeResult)
<T> void	setSwitchResult(String key, T t)
void	setWhileResult(String key, boolean whileFlag)

Methods inherited from class java.lang.Object

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

Field Detail

metaDataMap

protected ConcurrentHashMap<String,Object> metaDataMap

Constructor Detail

Slot

public Slot()

Slot

public Slot(List<cn.hutool.core.lang.Tuple> contextBeanList)

Method Detail

getInput

public <T> T getInput(String nodeId)

getOutput

public <T> T getOutput(String nodeId)

setInput

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

setOutput

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

getResponseData

public <T> T getResponseData()

setResponseData

public <T> void setResponseData(T t)

getChainReqData

public <T> T getChainReqData(String chainId)

setChainReqData

public <T> void setChainReqData(String chainId,
                                T t)

getChainReqDataFromQueue

public <T> T getChainReqDataFromQueue(String chainId)

setChainReqData2Queue

public <T> void setChainReqData2Queue(String chainId,
                                      T t)

setPrivateDeliveryData

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

getPrivateDeliveryQueue

public <T> Queue<T> getPrivateDeliveryQueue(String nodeId)

getPrivateDeliveryData

public <T> T getPrivateDeliveryData(String nodeId)

setSwitchResult

public <T> void setSwitchResult(String key,
                                T t)

getSwitchResult

public <T> T getSwitchResult(String key)

setIfResult

public void setIfResult(String key,
                        boolean result)

getIfResult

public Boolean getIfResult(String key)

setAndOrResult

public void setAndOrResult(String key,
                           boolean result)

getAndOrResult

public Boolean getAndOrResult(String key)

setNotResult

public void setNotResult(String key,
                         boolean result)

getNotResult

public Boolean getNotResult(String key)

setForResult

public void setForResult(String key,
                         int forCount)

getForResult

public Integer getForResult(String key)

setWhileResult

public void setWhileResult(String key,
                           boolean whileFlag)

getWhileResult

public Boolean getWhileResult(String key)

setBreakResult

public void setBreakResult(String key,
                           boolean breakFlag)

getBreakResult

public Boolean getBreakResult(String key)

setIteratorResult

public void setIteratorResult(String key,
                              Iterator<?> it)

getIteratorResult

public Iterator<?> getIteratorResult(String key)

getCurrentCondition

public Condition getCurrentCondition()

pushCondition

public void pushCondition(Condition condition)

popCondition

public void popCondition()

setChainName

@Deprecated
public void setChainName(String chainName)

Deprecated. 请使用 setChainId(String)

getChainName

@Deprecated
public String getChainName()

Deprecated. 请使用 getChainId()

setChainId

public void setChainId(String chainId)

getChainId

public String getChainId()

addChainInstance

public void addChainInstance(Chain chain)

getCurrentChainInstance

public Chain getCurrentChainInstance(String currentChainId)

addStep

public void addStep(CmpStep step)

getExecuteStepStr

public String getExecuteStepStr(boolean withTimeSpent)

getExecuteStepStrWithInstanceId

public String getExecuteStepStrWithInstanceId()

getExecuteStepStr

public String getExecuteStepStr()

printStep

public void printStep()

addRollbackStep

public void addRollbackStep(CmpStep step)

getRollbackStepStr

public String getRollbackStepStr(boolean withRollbackTimeSpent)

getRollbackStepStr

public String getRollbackStepStr()

printRollbackStep

public void printRollbackStep()

generateRequestId

public void generateRequestId()

putRequestId

public void putRequestId(String requestId)

getRequestId

public String getRequestId()

getExecuteSteps

public Deque<CmpStep> getExecuteSteps()

getRollbackSteps

public Deque<CmpStep> getRollbackSteps()

getException

public Exception getException()

setException

public void setException(Exception e)

removeException

public void removeException()

getSubException

public Exception getSubException(String chainId)

getContextBeanList

public List<cn.hutool.core.lang.Tuple> getContextBeanList()

getContextBean

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

getContextBean

public <T> T getContextBean(String contextBeanKey)

getFirstContextBean

public <T> T getFirstContextBean()

getRouteResult

public Boolean getRouteResult()

setRouteResult

public void setRouteResult(Boolean routeResult)

addTimeoutItem

public void addTimeoutItem(String executorItem)

getTimeoutItemList

public List<String> getTimeoutItemList()