Package org.jbpm.workflow.instance.impl
Class WorkflowProcessInstanceImpl
- java.lang.Object
-
- org.jbpm.process.instance.impl.ProcessInstanceImpl
-
- org.jbpm.workflow.instance.impl.WorkflowProcessInstanceImpl
-
- All Implemented Interfaces:
Serializable,ContextableInstance,ContextInstanceContainer,ProcessInstance,NodeInstanceContainer,WorkflowProcessInstance,org.kie.api.runtime.process.EventListener,org.kie.api.runtime.process.NodeInstanceContainer,org.kie.api.runtime.process.ProcessInstance,org.kie.api.runtime.process.WorkflowProcessInstance
- Direct Known Subclasses:
RuleFlowProcessInstance
public abstract class WorkflowProcessInstanceImpl extends ProcessInstanceImpl implements WorkflowProcessInstance, NodeInstanceContainer
Default implementation of a RuleFlow process instance.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description WorkflowProcessInstanceImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddActivatingNodeId(String uniqueId)voidaddCompletedNodeId(String uniqueId)voidaddEventListener(String type, org.kie.api.runtime.process.EventListener listener, boolean external)voidaddNodeInstance(NodeInstance nodeInstance)voidcancelTimer(long timerId)voidconfigureSLA()TimerInstanceconfigureSLATimer(String slaDueDateExpression)TimerInstanceconfigureSLATimer(String slaDueDateExpression, String timerName)TimerInstanceconfigureTimer(String timerExpression, String timerName, boolean trackTimer)voiddisconnect()List<String>getActivatingNodeIds()List<String>getActiveNodeIds()org.kie.api.runtime.rule.AgendaFiltergetAgendaFilter()List<String>getCompletedNodeIds()StringgetCorrelationKey()intgetCurrentLevel()StringgetDeploymentId()Function<String,Object>getEventFilterResolver(org.kie.api.runtime.process.NodeInstanceContainer container, org.kie.api.definition.process.Node node, List<NodeInstance> currentView)String[]getEventTypes()ObjectgetFaultData()NodeInstancegetFirstNodeInstance(long nodeId)Map<String,Integer>getIterationLevels()intgetLevelForNode(String uniqueID)org.kie.api.definition.process.NodeContainergetNodeContainer()NodeInstancegetNodeInstance(long nodeInstanceId)NodeInstancegetNodeInstance(long nodeInstanceId, boolean recursive)NodeInstancegetNodeInstance(org.kie.api.definition.process.Node node)NodeInstancegetNodeInstance(org.kie.api.definition.process.Node node, boolean wrap)NodeInstancegetNodeInstanceByNodeId(long nodeId, boolean recursive)longgetNodeInstanceCounter()Collection<org.kie.api.runtime.process.NodeInstance>getNodeInstances()Collection<NodeInstance>getNodeInstances(boolean recursive)List<NodeInstance>getNodeInstances(long nodeId)List<NodeInstance>getNodeInstances(long nodeId, List<NodeInstance> currentView)intgetSlaCompliance()DategetSlaDueDate()LonggetSlaTimerId()DategetStartDate()ObjectgetVariable(String name)ObjectgetVariable(String name, List<ContextInstance> variableScopeInstances)Map<String,Object>getVariables()org.kie.api.definition.process.WorkflowProcessgetWorkflowProcess()protected booleanhasDeploymentId()AtomicLonginternalGetNodeInstanceCounter()voidinternalSetNodeInstanceCounter(long nodeInstanceCounter)voidinternalSetSlaCompliance(int slaCompliance)voidinternalSetSlaDueDate(Date slaDueDate)voidinternalSetSlaTimerId(Long slaTimerId)voidinternalSetStartDate(Date startDate)booleanisPersisted()booleanisSignalCompletion()voidnodeInstanceCompleted(NodeInstance nodeInstance, String outType)voidreconnect()protected voidregisterExternalEventNodeListeners()voidremoveEventListener(String type, org.kie.api.runtime.process.EventListener listener, boolean external)voidremoveNodeInstance(NodeInstance nodeInstance)protected List<String>resolveVariables(List<String> events)voidsetAgendaFilter(org.kie.api.runtime.rule.AgendaFilter agendaFilter)voidsetCorrelationKey(String correlationKey)voidsetCurrentLevel(int currentLevel)voidsetDeploymentId(String deploymentId)voidsetPersisted(boolean persisted)voidsetSignalCompletion(boolean signalCompletion)voidsetState(int state)voidsetState(int state, String outcome)voidsetState(int state, String outcome, Object faultData)voidsetVariable(String name, Object value)voidsignalEvent(String type, Object event)voidstart()voidstart(String trigger)StringtoString()protected booleanuseAsync(org.kie.api.definition.process.Node node)protected booleanuseTimerSLATracking()-
Methods inherited from class org.jbpm.process.instance.impl.ProcessInstanceImpl
addContextInstance, getAgenda, getContextContainer, getContextInstance, getContextInstance, getContextInstance, getContextInstances, getDescription, getId, getKnowledgeRuntime, getMetaData, getOutcome, getParentProcessInstanceId, getProcess, getProcessId, getProcessName, getProcessXml, getState, internalSetState, internalStart, removeContextInstance, setContextInstance, setDescription, setId, setKnowledgeRuntime, setMetaData, setOutcome, setParentProcessInstanceId, setProcess, setProcessId, setProcessXml, updateProcess
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.jbpm.process.instance.ContextableInstance
getContextInstance
-
Methods inherited from interface org.jbpm.process.instance.ContextInstanceContainer
addContextInstance, getContextContainer, getContextInstance, getContextInstance, getContextInstances, removeContextInstance
-
Methods inherited from interface org.jbpm.workflow.instance.NodeInstanceContainer
getState
-
Methods inherited from interface org.jbpm.process.instance.ProcessInstance
getKnowledgeRuntime, getMetaData, getOutcome, getProcess, setId, setKnowledgeRuntime, setParentProcessInstanceId, setProcess
-
-
-
-
Method Detail
-
getNodeContainer
public org.kie.api.definition.process.NodeContainer getNodeContainer()
- Specified by:
getNodeContainerin interfaceNodeInstanceContainer
-
addNodeInstance
public void addNodeInstance(NodeInstance nodeInstance)
- Specified by:
addNodeInstancein interfaceNodeInstanceContainer
-
getLevelForNode
public int getLevelForNode(String uniqueID)
- Specified by:
getLevelForNodein interfaceNodeInstanceContainer
-
removeNodeInstance
public void removeNodeInstance(NodeInstance nodeInstance)
- Specified by:
removeNodeInstancein interfaceNodeInstanceContainer
-
getNodeInstances
public Collection<org.kie.api.runtime.process.NodeInstance> getNodeInstances()
- Specified by:
getNodeInstancesin interfaceorg.kie.api.runtime.process.NodeInstanceContainer
-
getNodeInstances
public Collection<NodeInstance> getNodeInstances(boolean recursive)
- Specified by:
getNodeInstancesin interfaceNodeInstanceContainer
-
getNodeInstance
public NodeInstance getNodeInstance(long nodeInstanceId)
- Specified by:
getNodeInstancein interfaceorg.kie.api.runtime.process.NodeInstanceContainer
-
getNodeInstanceByNodeId
public NodeInstance getNodeInstanceByNodeId(long nodeId, boolean recursive)
-
getNodeInstance
public NodeInstance getNodeInstance(long nodeInstanceId, boolean recursive)
- Specified by:
getNodeInstancein interfaceNodeInstanceContainer
-
getFirstNodeInstance
public NodeInstance getFirstNodeInstance(long nodeId)
- Specified by:
getFirstNodeInstancein interfaceNodeInstanceContainer
-
getNodeInstances
public List<NodeInstance> getNodeInstances(long nodeId)
-
getNodeInstances
public List<NodeInstance> getNodeInstances(long nodeId, List<NodeInstance> currentView)
-
getNodeInstance
public NodeInstance getNodeInstance(org.kie.api.definition.process.Node node)
- Specified by:
getNodeInstancein interfaceNodeInstanceContainer
-
getNodeInstance
public NodeInstance getNodeInstance(org.kie.api.definition.process.Node node, boolean wrap)
-
getNodeInstanceCounter
public long getNodeInstanceCounter()
-
internalSetNodeInstanceCounter
public void internalSetNodeInstanceCounter(long nodeInstanceCounter)
-
internalGetNodeInstanceCounter
public AtomicLong internalGetNodeInstanceCounter()
-
getWorkflowProcess
public org.kie.api.definition.process.WorkflowProcess getWorkflowProcess()
-
getVariable
public Object getVariable(String name)
- Specified by:
getVariablein interfaceorg.kie.api.runtime.process.WorkflowProcessInstance
-
getVariable
public Object getVariable(String name, List<ContextInstance> variableScopeInstances)
-
setVariable
public void setVariable(String name, Object value)
- Specified by:
setVariablein interfaceorg.kie.api.runtime.process.WorkflowProcessInstance
-
setState
public void setState(int state, String outcome, Object faultData)- Specified by:
setStatein interfaceProcessInstance
-
setState
public void setState(int state, String outcome)- Specified by:
setStatein interfaceProcessInstance- Overrides:
setStatein classProcessInstanceImpl
-
setState
public void setState(int state)
- Specified by:
setStatein interfaceNodeInstanceContainer- Specified by:
setStatein interfaceProcessInstance- Overrides:
setStatein classProcessInstanceImpl
-
disconnect
public void disconnect()
- Overrides:
disconnectin classProcessInstanceImpl
-
reconnect
public void reconnect()
- Overrides:
reconnectin classProcessInstanceImpl
-
toString
public String toString()
- Overrides:
toStringin classProcessInstanceImpl
-
start
public void start()
- Specified by:
startin interfaceProcessInstance- Overrides:
startin classProcessInstanceImpl
-
start
public void start(String trigger)
- Specified by:
startin interfaceProcessInstance- Overrides:
startin classProcessInstanceImpl
-
configureSLA
public void configureSLA()
- Specified by:
configureSLAin interfaceProcessInstance
-
configureSLATimer
public TimerInstance configureSLATimer(String slaDueDateExpression)
-
configureSLATimer
public TimerInstance configureSLATimer(String slaDueDateExpression, String timerName)
-
configureTimer
public TimerInstance configureTimer(String timerExpression, String timerName, boolean trackTimer)
-
cancelTimer
public void cancelTimer(long timerId)
-
registerExternalEventNodeListeners
protected void registerExternalEventNodeListeners()
-
signalEvent
public void signalEvent(String type, Object event)
- Specified by:
signalEventin interfaceorg.kie.api.runtime.process.EventListener- Overrides:
signalEventin classProcessInstanceImpl
-
getEventFilterResolver
public Function<String,Object> getEventFilterResolver(org.kie.api.runtime.process.NodeInstanceContainer container, org.kie.api.definition.process.Node node, List<NodeInstance> currentView)
-
addEventListener
public void addEventListener(String type, org.kie.api.runtime.process.EventListener listener, boolean external)
- Specified by:
addEventListenerin interfaceWorkflowProcessInstance
-
removeEventListener
public void removeEventListener(String type, org.kie.api.runtime.process.EventListener listener, boolean external)
- Specified by:
removeEventListenerin interfaceWorkflowProcessInstance
-
getEventTypes
public String[] getEventTypes()
- Specified by:
getEventTypesin interfaceorg.kie.api.runtime.process.EventListener- Overrides:
getEventTypesin classProcessInstanceImpl
-
nodeInstanceCompleted
public void nodeInstanceCompleted(NodeInstance nodeInstance, String outType)
- Specified by:
nodeInstanceCompletedin interfaceNodeInstanceContainer
-
addCompletedNodeId
public void addCompletedNodeId(String uniqueId)
-
getCurrentLevel
public int getCurrentLevel()
- Specified by:
getCurrentLevelin interfaceNodeInstanceContainer
-
setCurrentLevel
public void setCurrentLevel(int currentLevel)
- Specified by:
setCurrentLevelin interfaceNodeInstanceContainer
-
isPersisted
public boolean isPersisted()
-
setPersisted
public void setPersisted(boolean persisted)
-
addActivatingNodeId
public void addActivatingNodeId(String uniqueId)
-
getFaultData
public Object getFaultData()
- Specified by:
getFaultDatain interfaceProcessInstance
-
isSignalCompletion
public boolean isSignalCompletion()
- Specified by:
isSignalCompletionin interfaceProcessInstance
-
setSignalCompletion
public void setSignalCompletion(boolean signalCompletion)
- Specified by:
setSignalCompletionin interfaceProcessInstance
-
getDeploymentId
public String getDeploymentId()
- Specified by:
getDeploymentIdin interfaceProcessInstance
-
setDeploymentId
public void setDeploymentId(String deploymentId)
- Specified by:
setDeploymentIdin interfaceProcessInstance
-
getCorrelationKey
public String getCorrelationKey()
-
setCorrelationKey
public void setCorrelationKey(String correlationKey)
-
getStartDate
public Date getStartDate()
- Specified by:
getStartDatein interfaceProcessInstance
-
internalSetStartDate
public void internalSetStartDate(Date startDate)
-
hasDeploymentId
protected boolean hasDeploymentId()
-
useAsync
protected boolean useAsync(org.kie.api.definition.process.Node node)
-
useTimerSLATracking
protected boolean useTimerSLATracking()
-
getSlaCompliance
public int getSlaCompliance()
- Specified by:
getSlaCompliancein interfaceProcessInstance
-
internalSetSlaCompliance
public void internalSetSlaCompliance(int slaCompliance)
-
getSlaDueDate
public Date getSlaDueDate()
- Specified by:
getSlaDueDatein interfaceProcessInstance
-
internalSetSlaDueDate
public void internalSetSlaDueDate(Date slaDueDate)
-
getSlaTimerId
public Long getSlaTimerId()
-
internalSetSlaTimerId
public void internalSetSlaTimerId(Long slaTimerId)
-
getAgendaFilter
public org.kie.api.runtime.rule.AgendaFilter getAgendaFilter()
- Specified by:
getAgendaFilterin interfaceProcessInstance
-
setAgendaFilter
public void setAgendaFilter(org.kie.api.runtime.rule.AgendaFilter agendaFilter)
- Specified by:
setAgendaFilterin interfaceProcessInstance
-
-