public class ProcessServiceImpl extends Object implements org.jbpm.services.api.ProcessService, VariablesAware
Modifier and Type | Field and Description |
---|---|
protected org.jbpm.services.api.RuntimeDataService |
dataService |
protected org.jbpm.services.api.DeploymentService |
deploymentService |
Constructor and Description |
---|
ProcessServiceImpl() |
Modifier and Type | Method and Description |
---|---|
void |
abortProcessInstance(Long processInstanceId) |
void |
abortProcessInstance(String deploymentId,
Long processInstanceId) |
void |
abortProcessInstances(List<Long> processInstanceIds) |
void |
abortProcessInstances(String deploymentId,
List<Long> processInstanceIds) |
void |
abortWorkItem(Long id) |
void |
abortWorkItem(String deploymentId,
Long processInstanceId,
Long id) |
protected Collection<String> |
collectActiveSignals(Collection<org.kie.api.runtime.process.NodeInstance> activeNodes) |
void |
completeWorkItem(Long id,
Map<String,Object> results) |
void |
completeWorkItem(String deploymentId,
Long processInstanceId,
Long id,
Map<String,Object> results) |
protected void |
disallowWhenNotActive(org.jbpm.services.api.model.DeployedUnit deployedUnit,
org.kie.api.command.Command<?> cmd) |
protected void |
disposeRuntimeEngine(org.kie.api.runtime.manager.RuntimeManager manager,
org.kie.api.runtime.manager.RuntimeEngine engine) |
<T> T |
execute(String deploymentId,
org.kie.api.command.Command<T> command) |
<T> T |
execute(String deploymentId,
org.kie.api.runtime.manager.Context<?> context,
org.kie.api.command.Command<T> command) |
protected List<String> |
getActiveBoundaryNodesSignals(org.kie.api.runtime.process.ProcessInstance processInstance,
Collection<org.kie.api.runtime.process.NodeInstance> activeNodes) |
Collection<String> |
getAvailableSignals(Long processInstanceId) |
Collection<String> |
getAvailableSignals(String deploymentId,
Long processInstanceId) |
protected org.kie.api.runtime.manager.Context<?> |
getContext(Map<String,Object> params) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(org.kie.internal.process.CorrelationKey key) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(Long processInstanceId) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(String deploymentId,
org.kie.internal.process.CorrelationKey key) |
org.kie.api.runtime.process.ProcessInstance |
getProcessInstance(String deploymentId,
Long processInstanceId) |
Object |
getProcessInstanceVariable(Long processInstanceId,
String variableName) |
Object |
getProcessInstanceVariable(String deploymentId,
Long processInstanceId,
String variableName) |
Map<String,Object> |
getProcessInstanceVariables(Long processInstanceId) |
Map<String,Object> |
getProcessInstanceVariables(String deploymentId,
Long processInstanceId) |
org.kie.api.runtime.process.WorkItem |
getWorkItem(Long id) |
org.kie.api.runtime.process.WorkItem |
getWorkItem(String deploymentId,
Long processInstanceId,
Long id) |
List<org.kie.api.runtime.process.WorkItem> |
getWorkItemByProcessInstance(Long processInstanceId) |
List<org.kie.api.runtime.process.WorkItem> |
getWorkItemByProcessInstance(String deploymentId,
Long processInstanceId) |
<T> T |
process(T variables,
ClassLoader cl)
Generic processing method that might be simply returning same instance of variables
if no processing is required.
|
void |
setDataService(org.jbpm.services.api.RuntimeDataService dataService) |
void |
setDeploymentService(org.jbpm.services.api.DeploymentService deploymentService) |
void |
setProcessVariable(Long processInstanceId,
String variableId,
Object value) |
void |
setProcessVariable(String deploymentId,
Long processInstanceId,
String variableId,
Object value) |
void |
setProcessVariables(Long processInstanceId,
Map<String,Object> variables) |
void |
setProcessVariables(String deploymentId,
Long processInstanceId,
Map<String,Object> variables) |
void |
signalEvent(String deploymentId,
String signalName,
Object event) |
void |
signalProcessInstance(Long processInstanceId,
String signalName,
Object event) |
void |
signalProcessInstance(String deploymentId,
Long processInstanceId,
String signalName,
Object event) |
void |
signalProcessInstances(List<Long> processInstanceIds,
String signalName,
Object event) |
void |
signalProcessInstances(String deploymentId,
List<Long> processInstanceIds,
String signalName,
Object event) |
Long |
startProcess(String deploymentId,
String processId) |
Long |
startProcess(String deploymentId,
String processId,
org.kie.internal.process.CorrelationKey correlationKey) |
Long |
startProcess(String deploymentId,
String processId,
org.kie.internal.process.CorrelationKey correlationKey,
Map<String,Object> params) |
Long |
startProcess(String deploymentId,
String processId,
Map<String,Object> params) |
protected org.jbpm.services.api.DeploymentService deploymentService
protected org.jbpm.services.api.RuntimeDataService dataService
public void setDeploymentService(org.jbpm.services.api.DeploymentService deploymentService)
public void setDataService(org.jbpm.services.api.RuntimeDataService dataService)
public Long startProcess(String deploymentId, String processId)
startProcess
in interface org.jbpm.services.api.ProcessService
public Long startProcess(String deploymentId, String processId, Map<String,Object> params)
startProcess
in interface org.jbpm.services.api.ProcessService
public Long startProcess(String deploymentId, String processId, org.kie.internal.process.CorrelationKey correlationKey)
startProcess
in interface org.jbpm.services.api.ProcessService
public Long startProcess(String deploymentId, String processId, org.kie.internal.process.CorrelationKey correlationKey, Map<String,Object> params)
startProcess
in interface org.jbpm.services.api.ProcessService
public void abortProcessInstance(Long processInstanceId)
abortProcessInstance
in interface org.jbpm.services.api.ProcessService
public void abortProcessInstance(String deploymentId, Long processInstanceId)
abortProcessInstance
in interface org.jbpm.services.api.ProcessService
public void abortProcessInstances(List<Long> processInstanceIds)
abortProcessInstances
in interface org.jbpm.services.api.ProcessService
public void abortProcessInstances(String deploymentId, List<Long> processInstanceIds)
abortProcessInstances
in interface org.jbpm.services.api.ProcessService
public void signalProcessInstance(Long processInstanceId, String signalName, Object event)
signalProcessInstance
in interface org.jbpm.services.api.ProcessService
public void signalProcessInstance(String deploymentId, Long processInstanceId, String signalName, Object event)
signalProcessInstance
in interface org.jbpm.services.api.ProcessService
public void signalProcessInstances(List<Long> processInstanceIds, String signalName, Object event)
signalProcessInstances
in interface org.jbpm.services.api.ProcessService
public void signalProcessInstances(String deploymentId, List<Long> processInstanceIds, String signalName, Object event)
signalProcessInstances
in interface org.jbpm.services.api.ProcessService
public void signalEvent(String deploymentId, String signalName, Object event)
signalEvent
in interface org.jbpm.services.api.ProcessService
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(Long processInstanceId)
getProcessInstance
in interface org.jbpm.services.api.ProcessService
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(String deploymentId, Long processInstanceId)
getProcessInstance
in interface org.jbpm.services.api.ProcessService
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(org.kie.internal.process.CorrelationKey key)
getProcessInstance
in interface org.jbpm.services.api.ProcessService
public org.kie.api.runtime.process.ProcessInstance getProcessInstance(String deploymentId, org.kie.internal.process.CorrelationKey key)
getProcessInstance
in interface org.jbpm.services.api.ProcessService
public void setProcessVariable(Long processInstanceId, String variableId, Object value)
setProcessVariable
in interface org.jbpm.services.api.ProcessService
public void setProcessVariable(String deploymentId, Long processInstanceId, String variableId, Object value)
setProcessVariable
in interface org.jbpm.services.api.ProcessService
public void setProcessVariables(Long processInstanceId, Map<String,Object> variables)
setProcessVariables
in interface org.jbpm.services.api.ProcessService
public void setProcessVariables(String deploymentId, Long processInstanceId, Map<String,Object> variables)
setProcessVariables
in interface org.jbpm.services.api.ProcessService
public Object getProcessInstanceVariable(Long processInstanceId, String variableName)
getProcessInstanceVariable
in interface org.jbpm.services.api.ProcessService
public Object getProcessInstanceVariable(String deploymentId, Long processInstanceId, String variableName)
getProcessInstanceVariable
in interface org.jbpm.services.api.ProcessService
public Map<String,Object> getProcessInstanceVariables(Long processInstanceId)
getProcessInstanceVariables
in interface org.jbpm.services.api.ProcessService
public Map<String,Object> getProcessInstanceVariables(String deploymentId, Long processInstanceId)
getProcessInstanceVariables
in interface org.jbpm.services.api.ProcessService
public Collection<String> getAvailableSignals(Long processInstanceId)
getAvailableSignals
in interface org.jbpm.services.api.ProcessService
public Collection<String> getAvailableSignals(String deploymentId, Long processInstanceId)
getAvailableSignals
in interface org.jbpm.services.api.ProcessService
public void completeWorkItem(Long id, Map<String,Object> results)
completeWorkItem
in interface org.jbpm.services.api.ProcessService
public void completeWorkItem(String deploymentId, Long processInstanceId, Long id, Map<String,Object> results)
completeWorkItem
in interface org.jbpm.services.api.ProcessService
public void abortWorkItem(Long id)
abortWorkItem
in interface org.jbpm.services.api.ProcessService
public void abortWorkItem(String deploymentId, Long processInstanceId, Long id)
abortWorkItem
in interface org.jbpm.services.api.ProcessService
public org.kie.api.runtime.process.WorkItem getWorkItem(Long id)
getWorkItem
in interface org.jbpm.services.api.ProcessService
public org.kie.api.runtime.process.WorkItem getWorkItem(String deploymentId, Long processInstanceId, Long id)
getWorkItem
in interface org.jbpm.services.api.ProcessService
public List<org.kie.api.runtime.process.WorkItem> getWorkItemByProcessInstance(Long processInstanceId)
getWorkItemByProcessInstance
in interface org.jbpm.services.api.ProcessService
public List<org.kie.api.runtime.process.WorkItem> getWorkItemByProcessInstance(String deploymentId, Long processInstanceId)
getWorkItemByProcessInstance
in interface org.jbpm.services.api.ProcessService
public <T> T execute(String deploymentId, org.kie.api.command.Command<T> command)
execute
in interface org.jbpm.services.api.ProcessService
public <T> T execute(String deploymentId, org.kie.api.runtime.manager.Context<?> context, org.kie.api.command.Command<T> command)
execute
in interface org.jbpm.services.api.ProcessService
protected void disallowWhenNotActive(org.jbpm.services.api.model.DeployedUnit deployedUnit, org.kie.api.command.Command<?> cmd)
protected Collection<String> collectActiveSignals(Collection<org.kie.api.runtime.process.NodeInstance> activeNodes)
protected List<String> getActiveBoundaryNodesSignals(org.kie.api.runtime.process.ProcessInstance processInstance, Collection<org.kie.api.runtime.process.NodeInstance> activeNodes)
public <T> T process(T variables, ClassLoader cl)
VariablesAware
process
in interface VariablesAware
variables
- object that holds varialble(s)cl
- classloader that shall be used to operate on the variables e.g. project class loaderprotected void disposeRuntimeEngine(org.kie.api.runtime.manager.RuntimeManager manager, org.kie.api.runtime.manager.RuntimeEngine engine)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.