Class ExternalTaskManager
- java.lang.Object
-
- org.camunda.bpm.engine.impl.persistence.AbstractManager
-
- org.camunda.bpm.engine.impl.persistence.entity.ExternalTaskManager
-
- All Implemented Interfaces:
Session
public class ExternalTaskManager extends AbstractManager
- Author:
- Thorben Lindhauer
-
-
Field Summary
Fields Modifier and Type Field Description static QueryOrderingProperty
EXT_TASK_PRIORITY_ORDERING_PROPERTY
-
Constructor Summary
Constructors Constructor Description ExternalTaskManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ListQueryParameterObject
configureParameterizedQuery(java.lang.Object parameter)
protected void
configureQuery(ListQueryParameterObject parameter)
protected void
configureQuery(ExternalTaskQueryImpl query)
void
delete(ExternalTaskEntity externalTask)
java.util.List<ImmutablePair<java.lang.String,java.lang.String>>
findDeploymentIdMappingsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
ExternalTaskEntity
findExternalTaskById(java.lang.String id)
long
findExternalTaskCountByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
java.util.List<java.lang.String>
findExternalTaskIdsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
java.util.List<ExternalTaskEntity>
findExternalTasksByExecutionId(java.lang.String id)
java.util.List<ExternalTaskEntity>
findExternalTasksByProcessInstanceId(java.lang.String processInstanceId)
java.util.List<ExternalTask>
findExternalTasksByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
void
fireExternalTaskAvailableEvent()
void
insert(ExternalTaskEntity externalTask)
java.util.List<ExternalTaskEntity>
selectExternalTasksForTopics(java.util.Collection<TopicFetchInstruction> queryFilters, int maxResults, boolean usePriority)
java.util.List<java.lang.String>
selectTopicNamesByQuery(ExternalTaskQueryImpl externalTaskQuery)
protected void
updateExternalTaskSuspensionState(java.lang.String processInstanceId, java.lang.String processDefinitionId, java.lang.String processDefinitionKey, SuspensionState suspensionState)
void
updateExternalTaskSuspensionStateByProcessDefinitionId(java.lang.String processDefinitionId, SuspensionState suspensionState)
void
updateExternalTaskSuspensionStateByProcessDefinitionKey(java.lang.String processDefinitionKey, SuspensionState suspensionState)
void
updateExternalTaskSuspensionStateByProcessDefinitionKeyAndTenantId(java.lang.String processDefinitionKey, java.lang.String processDefinitionTenantId, SuspensionState suspensionState)
void
updateExternalTaskSuspensionStateByProcessInstanceId(java.lang.String processInstanceId, SuspensionState suspensionState)
-
Methods inherited from class org.camunda.bpm.engine.impl.persistence.AbstractManager
checkAuthorization, close, configureQuery, delete, deleteAuthorizations, deleteAuthorizationsForGroup, deleteAuthorizationsForUser, deleteDefaultAuthorizations, flush, getAttachmentManager, getAuthorizationManager, getBatchManager, getByteArrayManager, getCamundaFormDefinitionManager, getCaseDefinitionManager, getCaseExecutionManager, getCaseInstanceManager, getCommandContext, getCurrentAuthentication, getDbEntityManager, getDbSqlSession, getDecisionDefinitionManager, getDecisionRequirementsDefinitionManager, getDeploymentManager, getEventSubscriptionManager, getHistoricActivityInstanceManager, getHistoricBatchManager, getHistoricCaseActivityInstanceManager, getHistoricCaseInstanceManager, getHistoricDecisionInstanceManager, getHistoricDetailManager, getHistoricExternalTaskLogManager, getHistoricIdentityLinkManager, getHistoricIncidentManager, getHistoricJobLogManager, getHistoricProcessInstanceManager, getHistoricReportManager, getHistoricTaskInstanceManager, getHistoricVariableInstanceManager, getIdentityInfoManager, getIdentityLinkManager, getJobDefinitionManager, getJobManager, getProcessDefinitionManager, getProcessInstanceManager, getResourceAuthorizationProvider, getResourceManager, getSession, getTaskManager, getTaskReportManager, getTenantManager, getUserOperationLogManager, getVariableInstanceManager, insert, isAuthorizationEnabled, saveDefaultAuthorizations
-
-
-
-
Field Detail
-
EXT_TASK_PRIORITY_ORDERING_PROPERTY
public static QueryOrderingProperty EXT_TASK_PRIORITY_ORDERING_PROPERTY
-
-
Method Detail
-
findExternalTaskById
public ExternalTaskEntity findExternalTaskById(java.lang.String id)
-
insert
public void insert(ExternalTaskEntity externalTask)
-
delete
public void delete(ExternalTaskEntity externalTask)
-
findExternalTasksByExecutionId
public java.util.List<ExternalTaskEntity> findExternalTasksByExecutionId(java.lang.String id)
-
findExternalTasksByProcessInstanceId
public java.util.List<ExternalTaskEntity> findExternalTasksByProcessInstanceId(java.lang.String processInstanceId)
-
selectExternalTasksForTopics
public java.util.List<ExternalTaskEntity> selectExternalTasksForTopics(java.util.Collection<TopicFetchInstruction> queryFilters, int maxResults, boolean usePriority)
-
findExternalTasksByQueryCriteria
public java.util.List<ExternalTask> findExternalTasksByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
-
findExternalTaskIdsByQueryCriteria
public java.util.List<java.lang.String> findExternalTaskIdsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
-
findDeploymentIdMappingsByQueryCriteria
public java.util.List<ImmutablePair<java.lang.String,java.lang.String>> findDeploymentIdMappingsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
-
findExternalTaskCountByQueryCriteria
public long findExternalTaskCountByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
-
selectTopicNamesByQuery
public java.util.List<java.lang.String> selectTopicNamesByQuery(ExternalTaskQueryImpl externalTaskQuery)
-
updateExternalTaskSuspensionState
protected void updateExternalTaskSuspensionState(java.lang.String processInstanceId, java.lang.String processDefinitionId, java.lang.String processDefinitionKey, SuspensionState suspensionState)
-
updateExternalTaskSuspensionStateByProcessInstanceId
public void updateExternalTaskSuspensionStateByProcessInstanceId(java.lang.String processInstanceId, SuspensionState suspensionState)
-
updateExternalTaskSuspensionStateByProcessDefinitionId
public void updateExternalTaskSuspensionStateByProcessDefinitionId(java.lang.String processDefinitionId, SuspensionState suspensionState)
-
updateExternalTaskSuspensionStateByProcessDefinitionKey
public void updateExternalTaskSuspensionStateByProcessDefinitionKey(java.lang.String processDefinitionKey, SuspensionState suspensionState)
-
updateExternalTaskSuspensionStateByProcessDefinitionKeyAndTenantId
public void updateExternalTaskSuspensionStateByProcessDefinitionKeyAndTenantId(java.lang.String processDefinitionKey, java.lang.String processDefinitionTenantId, SuspensionState suspensionState)
-
configureQuery
protected void configureQuery(ExternalTaskQueryImpl query)
-
configureQuery
protected void configureQuery(ListQueryParameterObject parameter)
-
configureParameterizedQuery
protected ListQueryParameterObject configureParameterizedQuery(java.lang.Object parameter)
-
fireExternalTaskAvailableEvent
public void fireExternalTaskAvailableEvent()
-
-