|
jBPM :: Distribution 6.2.0-SNAPSHOT | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jbpm.kie.services.impl.RuntimeDataServiceImpl
public class RuntimeDataServiceImpl
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.jbpm.services.api.RuntimeDataService |
---|
RuntimeDataService.EntryType |
Field Summary | |
---|---|
protected Set<ProcessDefinition> |
availableProcesses
|
protected Map<String,List<String>> |
deploymentsRoles
|
protected Map<String,List<String>> |
userDeploymentIdsCache
|
Constructor Summary | |
---|---|
RuntimeDataServiceImpl()
|
Method Summary | ||
---|---|---|
protected void |
applyDeploymentFilter(Map<String,Object> params)
|
|
protected
|
applyPagnition(List<T> input,
org.kie.internal.query.QueryContext queryContext)
|
|
protected void |
applyQueryContext(Map<String,Object> params,
org.kie.internal.query.QueryContext queryContext)
|
|
protected void |
applyQueryFilter(Map<String,Object> params,
org.kie.internal.query.QueryFilter queryFilter)
|
|
protected void |
applySorting(List<ProcessDefinition> input,
org.kie.internal.query.QueryContext queryContext)
|
|
List<org.kie.internal.task.api.AuditTask> |
getAllAuditTask(String userId,
org.kie.internal.query.QueryFilter filter)
Get a list of tasks audit logs for the user provides applying the query filter listed statuses. |
|
protected List<String> |
getDeploymentsForUser()
|
|
NodeInstanceDesc |
getNodeInstanceForWorkItem(Long workItemId)
Returns active node instance descriptor for given work item id, if exists. |
|
ProcessDefinition |
getProcessById(String processId)
Returns process definition for given process id |
|
Collection<ProcessDefinition> |
getProcesses(org.kie.internal.query.QueryContext queryContext)
Returns all process definitions available |
|
Collection<ProcessDefinition> |
getProcessesByDeploymentId(String deploymentId,
org.kie.internal.query.QueryContext queryContext)
Returns list of process definitions for given deployment id |
|
ProcessDefinition |
getProcessesByDeploymentIdProcessId(String deploymentId,
String processId)
Returns process definition for given deployment and process identifiers |
|
Collection<ProcessDefinition> |
getProcessesByFilter(String filter,
org.kie.internal.query.QueryContext queryContext)
Returns list of process definitions that match the given filter |
|
Collection<String> |
getProcessIds(String deploymentId,
org.kie.internal.query.QueryContext queryContext)
Returns list of process definition identifiers for given deployment id |
|
ProcessInstanceDesc |
getProcessInstanceById(long processId)
Returns process instance descriptions found for given processInstanceId if found otherwise null. |
|
Collection<NodeInstanceDesc> |
getProcessInstanceFullHistory(long processId,
org.kie.internal.query.QueryContext queryContext)
Returns complete trace of all executed (completed) and active nodes for given process instance id |
|
Collection<NodeInstanceDesc> |
getProcessInstanceFullHistoryByType(long processId,
RuntimeDataService.EntryType type,
org.kie.internal.query.QueryContext queryContext)
Returns complete trace of all events of given type (START or END) for given process instance. |
|
protected Collection<NodeInstanceDesc> |
getProcessInstanceHistory(long processId,
boolean completed,
org.kie.internal.query.QueryContext queryContext)
|
|
Collection<NodeInstanceDesc> |
getProcessInstanceHistoryActive(long processId,
org.kie.internal.query.QueryContext queryContext)
Returns trace of all active nodes for given process instance id |
|
Collection<NodeInstanceDesc> |
getProcessInstanceHistoryCompleted(long processId,
org.kie.internal.query.QueryContext queryContext)
Returns trace of all executed (completed) for given process instance id |
|
Collection<ProcessInstanceDesc> |
getProcessInstances(List<Integer> states,
String initiator,
org.kie.internal.query.QueryContext queryContext)
Returns list of process instance descriptions found with given statuses and initiated by initiator . |
|
Collection<ProcessInstanceDesc> |
getProcessInstances(org.kie.internal.query.QueryContext queryContext)
Returns list of process instance descriptions |
|
Collection<ProcessInstanceDesc> |
getProcessInstancesByDeploymentId(String deploymentId,
List<Integer> states,
org.kie.internal.query.QueryContext queryContext)
Returns list of process instance descriptions found for given deployment id and statuses. |
|
Collection<ProcessInstanceDesc> |
getProcessInstancesByProcessDefinition(String processDefId,
List<Integer> states,
org.kie.internal.query.QueryContext queryContext)
Returns list of process instance descriptions found for given process definition id |
|
Collection<ProcessInstanceDesc> |
getProcessInstancesByProcessDefinition(String processDefId,
org.kie.internal.query.QueryContext queryContext)
Returns list of process instance descriptions found for given process definition id |
|
Collection<ProcessInstanceDesc> |
getProcessInstancesByProcessId(List<Integer> states,
String processId,
String initiator,
org.kie.internal.query.QueryContext queryContext)
Returns list of process instance descriptions found for given process id and statuses and initiated by initiator |
|
Collection<ProcessInstanceDesc> |
getProcessInstancesByProcessName(List<Integer> states,
String processName,
String initiator,
org.kie.internal.query.QueryContext queryContext)
|
|
UserTaskInstanceDesc |
getTaskById(Long taskId)
Return a task by its taskId. |
|
UserTaskInstanceDesc |
getTaskByWorkItemId(Long workItemId)
Return a task by its workItemId. |
|
List<TaskSummary> |
getTasksAssignedAsBusinessAdministrator(String userId,
org.kie.internal.query.QueryFilter filter)
Return a list of assigned tasks as a Business Administrator. |
|
List<TaskSummary> |
getTasksAssignedAsPotentialOwner(String userId,
List<String> groupIds,
List<Status> status,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user or groups are eligible for with one of the listed statuses. |
|
List<TaskSummary> |
getTasksAssignedAsPotentialOwner(String userId,
List<String> groupIds,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user or groups are eligible for. |
|
List<TaskSummary> |
getTasksAssignedAsPotentialOwner(String userId,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user is eligible for. |
|
List<TaskSummary> |
getTasksAssignedAsPotentialOwnerByExpirationDateOptional(String userId,
List<Status> status,
Date from,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user is eligible for with one of the listed statuses and expiration date starting at from . |
|
List<TaskSummary> |
getTasksAssignedAsPotentialOwnerByStatus(String userId,
List<Status> status,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user is eligible for with one of the listed statuses. |
|
List<Long> |
getTasksByProcessInstanceId(Long processInstanceId)
Get a list of tasks the Process Instance is waiting on. |
|
List<TaskSummary> |
getTasksByStatusByProcessInstanceId(Long processInstanceId,
List<Status> status,
org.kie.internal.query.QueryFilter filter)
Get a list of tasks the Process Instance is waiting on with one of the listed statuses. |
|
List<TaskSummary> |
getTasksOwned(String userId,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user has claimed. |
|
List<TaskSummary> |
getTasksOwnedByExpirationDateOptional(String userId,
List<Status> strStatuses,
Date from,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user has claimed with one of the listed statuses and expiration date starting at from . |
|
List<TaskSummary> |
getTasksOwnedByStatus(String userId,
List<Status> status,
org.kie.internal.query.QueryFilter filter)
Return a list of tasks the user has claimed with one of the listed statuses. |
|
Collection<VariableDesc> |
getVariableHistory(long processInstanceId,
String variableId,
org.kie.internal.query.QueryContext queryContext)
Returns collection of changes to given variable within scope of process instance |
|
Collection<VariableDesc> |
getVariablesCurrentState(long processInstanceId)
Returns collections of all process variables current value for given process instance |
|
void |
onActivate(DeploymentEvent event)
|
|
void |
onDeactivate(DeploymentEvent event)
|
|
void |
onDeploy(DeploymentEvent event)
|
|
void |
onUnDeploy(DeploymentEvent event)
|
|
void |
setCommandService(TransactionalCommandService commandService)
|
|
void |
setIdentityProvider(org.kie.internal.identity.IdentityProvider identityProvider)
|
|
void |
setTaskService(TaskService taskService)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Set<ProcessDefinition> availableProcesses
protected Map<String,List<String>> deploymentsRoles
protected Map<String,List<String>> userDeploymentIdsCache
Constructor Detail |
---|
public RuntimeDataServiceImpl()
Method Detail |
---|
public void setCommandService(TransactionalCommandService commandService)
public void setIdentityProvider(org.kie.internal.identity.IdentityProvider identityProvider)
public void setTaskService(TaskService taskService)
public void onDeploy(DeploymentEvent event)
onDeploy
in interface DeploymentEventListener
public void onUnDeploy(DeploymentEvent event)
onUnDeploy
in interface DeploymentEventListener
public void onActivate(DeploymentEvent event)
onActivate
in interface DeploymentEventListener
public void onDeactivate(DeploymentEvent event)
onDeactivate
in interface DeploymentEventListener
protected void applyQueryContext(Map<String,Object> params, org.kie.internal.query.QueryContext queryContext)
protected List<String> getDeploymentsForUser()
protected void applyDeploymentFilter(Map<String,Object> params)
protected <T> Collection<T> applyPagnition(List<T> input, org.kie.internal.query.QueryContext queryContext)
protected void applySorting(List<ProcessDefinition> input, org.kie.internal.query.QueryContext queryContext)
public Collection<ProcessDefinition> getProcessesByDeploymentId(String deploymentId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessesByDeploymentId
in interface RuntimeDataService
deploymentId
- The deployment id of the runtime.queryContext
- control parameters for the result e.g. sorting, paging
ProcessAssetDesc
instances representing processes that match
the given criteria (deploymentId)public ProcessDefinition getProcessesByDeploymentIdProcessId(String deploymentId, String processId)
RuntimeDataService
getProcessesByDeploymentIdProcessId
in interface RuntimeDataService
deploymentId
- The id of the deployment (runtime)processId
- The id of the process
ProcessAssetDesc
instance, representing the Process
that is present in the specified deployment with the specified (process) id.public Collection<ProcessDefinition> getProcessesByFilter(String filter, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessesByFilter
in interface RuntimeDataService
filter
- A regular expression.queryContext
- control parameters for the result e.g. sorting, paging
ProcessAssetDesc
instances whose name or id matches the given regular expression.public ProcessDefinition getProcessById(String processId)
RuntimeDataService
getProcessById
in interface RuntimeDataService
processId
- The id of the process
ProcessAssetDesc
instance, representing the Process
with the specified (process) id.public Collection<ProcessDefinition> getProcesses(org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcesses
in interface RuntimeDataService
queryContext
- control parameters for the result e.g. sorting, paging
ProcessAssetDesc
instances.public Collection<String> getProcessIds(String deploymentId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessIds
in interface RuntimeDataService
deploymentId
- The deployment id of the runtime.queryContext
- control parameters for the result e.g. sorting, paging
public Collection<ProcessInstanceDesc> getProcessInstances(org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstances
in interface RuntimeDataService
queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the available process instances.public Collection<ProcessInstanceDesc> getProcessInstances(List<Integer> states, String initiator, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
initiator
.
getProcessInstances
in interface RuntimeDataService
states
- A list of possible state (int) values that the ProcessInstance
can have.initiator
- The initiator of the ProcessInstance
.queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the process instances that match
the given criteria (states and initiator).public Collection<ProcessInstanceDesc> getProcessInstancesByDeploymentId(String deploymentId, List<Integer> states, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstancesByDeploymentId
in interface RuntimeDataService
deploymentId
- The deployment id of the runtime.states
- A list of possible state (int) values that the ProcessInstance
can have.queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the process instances that match
the given criteria (deploymentId and states).public Collection<ProcessInstanceDesc> getProcessInstancesByProcessDefinition(String processDefId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstancesByProcessDefinition
in interface RuntimeDataService
processDefId
- The id of the process (definition)queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the process instances that match
the given criteria (deploymentId and states).public Collection<ProcessInstanceDesc> getProcessInstancesByProcessDefinition(String processDefId, List<Integer> states, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstancesByProcessDefinition
in interface RuntimeDataService
processDefId
- The id of the process (definition)states
- A list of possible state (int) values that the ProcessInstance
can have.queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the process instances that match
the given criteria (deploymentId and states).public ProcessInstanceDesc getProcessInstanceById(long processId)
RuntimeDataService
getProcessInstanceById
in interface RuntimeDataService
processId
- The id of the process instance to be fetched
ProcessInstanceDesc
instance.public Collection<ProcessInstanceDesc> getProcessInstancesByProcessId(List<Integer> states, String processId, String initiator, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
initiator
getProcessInstancesByProcessId
in interface RuntimeDataService
states
- A list of possible state (int) values that the ProcessInstance
can have.processId
- The id of the Process
(definition) used when starting the process instance.initiator
- The initiator of the ProcessInstance
.queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the process instances that match
the given criteria (states, processId, and initiator).public Collection<ProcessInstanceDesc> getProcessInstancesByProcessName(List<Integer> states, String processName, String initiator, org.kie.internal.query.QueryContext queryContext)
getProcessInstancesByProcessName
in interface RuntimeDataService
states
- A list of possible state (int) values that the ProcessInstance
can have.processName
- The name (not id!) of the Process
(definition) used when starting the process instance.initiator
- The initiator of the ProcessInstance
.queryContext
- control parameters for the result e.g. sorting, paging
ProcessInstanceDesc
instances representing the process instances that match
the given criteria (states, processName and initiator).public Collection<NodeInstanceDesc> getProcessInstanceHistoryActive(long processId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstanceHistoryActive
in interface RuntimeDataService
processId
- unique identifier of process instancequeryContext
- control parameters for the result e.g. sorting, paging
public Collection<NodeInstanceDesc> getProcessInstanceHistoryCompleted(long processId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstanceHistoryCompleted
in interface RuntimeDataService
processId
- unique identifier of process instancequeryContext
- control parameters for the result e.g. sorting, paging
protected Collection<NodeInstanceDesc> getProcessInstanceHistory(long processId, boolean completed, org.kie.internal.query.QueryContext queryContext)
public Collection<NodeInstanceDesc> getProcessInstanceFullHistory(long processId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstanceFullHistory
in interface RuntimeDataService
processId
- The id of the process used to start the process instance.queryContext
- control parameters for the result e.g. sorting, paging
NodeInstance
information, in the form of a list of NodeInstanceDesc
instances,
that comes from a process instance that matches the given criteria (deploymentId, processId).public Collection<NodeInstanceDesc> getProcessInstanceFullHistoryByType(long processId, RuntimeDataService.EntryType type, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getProcessInstanceFullHistoryByType
in interface RuntimeDataService
processId
- The id of the process used to start the process instance.type
- type of events that shall be returned (START or END) - to return both use #getProcessInstanceFullHistory(String, long)
queryContext
- control parameters for the result e.g. sorting, paging
public NodeInstanceDesc getNodeInstanceForWorkItem(Long workItemId)
RuntimeDataService
getNodeInstanceForWorkItem
in interface RuntimeDataService
workItemId
- identifier of the work item
public Collection<VariableDesc> getVariablesCurrentState(long processInstanceId)
RuntimeDataService
getVariablesCurrentState
in interface RuntimeDataService
processInstanceId
- The process instance id.
VariableStateDesc
instances.public Collection<VariableDesc> getVariableHistory(long processInstanceId, String variableId, org.kie.internal.query.QueryContext queryContext)
RuntimeDataService
getVariableHistory
in interface RuntimeDataService
processInstanceId
- The process instance id.variableId
- The id of the variablequeryContext
- control parameters for the result e.g. sorting, paging
VariableStateDesc
instances.public UserTaskInstanceDesc getTaskByWorkItemId(Long workItemId)
RuntimeDataService
getTaskByWorkItemId
in interface RuntimeDataService
public UserTaskInstanceDesc getTaskById(Long taskId)
RuntimeDataService
getTaskById
in interface RuntimeDataService
public List<TaskSummary> getTasksAssignedAsBusinessAdministrator(String userId, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksAssignedAsBusinessAdministrator
in interface RuntimeDataService
public List<TaskSummary> getTasksAssignedAsPotentialOwner(String userId, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksAssignedAsPotentialOwner
in interface RuntimeDataService
public List<TaskSummary> getTasksAssignedAsPotentialOwner(String userId, List<String> groupIds, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksAssignedAsPotentialOwner
in interface RuntimeDataService
public List<TaskSummary> getTasksAssignedAsPotentialOwner(String userId, List<String> groupIds, List<Status> status, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksAssignedAsPotentialOwner
in interface RuntimeDataService
public List<TaskSummary> getTasksAssignedAsPotentialOwnerByStatus(String userId, List<Status> status, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksAssignedAsPotentialOwnerByStatus
in interface RuntimeDataService
public List<TaskSummary> getTasksAssignedAsPotentialOwnerByExpirationDateOptional(String userId, List<Status> status, Date from, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
from
. Tasks that do not have expiration date set
will also be included in the result set.
getTasksAssignedAsPotentialOwnerByExpirationDateOptional
in interface RuntimeDataService
public List<TaskSummary> getTasksOwnedByExpirationDateOptional(String userId, List<Status> strStatuses, Date from, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
from
. Tasks that do not have expiration date set
will also be included in the result set.
getTasksOwnedByExpirationDateOptional
in interface RuntimeDataService
public List<TaskSummary> getTasksOwned(String userId, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksOwned
in interface RuntimeDataService
public List<TaskSummary> getTasksOwnedByStatus(String userId, List<Status> status, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksOwnedByStatus
in interface RuntimeDataService
public List<Long> getTasksByProcessInstanceId(Long processInstanceId)
RuntimeDataService
getTasksByProcessInstanceId
in interface RuntimeDataService
public List<TaskSummary> getTasksByStatusByProcessInstanceId(Long processInstanceId, List<Status> status, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getTasksByStatusByProcessInstanceId
in interface RuntimeDataService
public List<org.kie.internal.task.api.AuditTask> getAllAuditTask(String userId, org.kie.internal.query.QueryFilter filter)
RuntimeDataService
getAllAuditTask
in interface RuntimeDataService
protected void applyQueryFilter(Map<String,Object> params, org.kie.internal.query.QueryFilter queryFilter)
|
jBPM :: Distribution 6.2.0-SNAPSHOT | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |