Package org.camunda.bpm.engine.impl.persistence.entity

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

Constructor Summary

Constructors

Constructor	Description
ExternalTaskManager()

Method Summary

Modifier and Type	Method	Description
protected ListQueryParameterObject	configureParameterizedQuery(Object parameter)
protected void	configureQuery(ListQueryParameterObject parameter)
protected void	configureQuery(ExternalTaskQueryImpl query)
void	delete(ExternalTaskEntity externalTask)
List<ImmutablePair<String,String>>	findDeploymentIdMappingsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
ExternalTaskEntity	findExternalTaskById(String id)
long	findExternalTaskCountByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
List<String>	findExternalTaskIdsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
List<ExternalTaskEntity>	findExternalTasksByExecutionId(String id)
List<ExternalTaskEntity>	findExternalTasksByProcessInstanceId(String processInstanceId)
List<ExternalTask>	findExternalTasksByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)
void	fireExternalTaskAvailableEvent()
void	insert(ExternalTaskEntity externalTask)
List<ExternalTaskEntity>	selectExternalTasksForTopics(Collection<TopicFetchInstruction> queryFilters, int maxResults, List<QueryOrderingProperty> orderingProperties)
List<String>	selectTopicNamesByQuery(ExternalTaskQueryImpl externalTaskQuery)
protected boolean	shouldApplyOrdering(boolean usePriority, boolean useCreateTime)
protected void	updateExternalTaskSuspensionState(String processInstanceId, String processDefinitionId, String processDefinitionKey, SuspensionState suspensionState)
void	updateExternalTaskSuspensionStateByProcessDefinitionId(String processDefinitionId, SuspensionState suspensionState)
void	updateExternalTaskSuspensionStateByProcessDefinitionKey(String processDefinitionKey, SuspensionState suspensionState)
void	updateExternalTaskSuspensionStateByProcessDefinitionKeyAndTenantId(String processDefinitionKey, String processDefinitionTenantId, SuspensionState suspensionState)
void	updateExternalTaskSuspensionStateByProcessInstanceId(String processInstanceId, SuspensionState suspensionState)
protected boolean	useCreateTime(List<QueryOrderingProperty> orderingProperties)

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

Methods inherited from class java.lang.Object

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

Constructor Details

ExternalTaskManager

public ExternalTaskManager()

Method Details

findExternalTaskById

public ExternalTaskEntity findExternalTaskById(String id)

insert

public void insert(ExternalTaskEntity externalTask)

delete

public void delete(ExternalTaskEntity externalTask)

findExternalTasksByExecutionId

public List<ExternalTaskEntity> findExternalTasksByExecutionId(String id)

findExternalTasksByProcessInstanceId

public List<ExternalTaskEntity> findExternalTasksByProcessInstanceId(String processInstanceId)

selectExternalTasksForTopics

public List<ExternalTaskEntity> selectExternalTasksForTopics(Collection<TopicFetchInstruction> queryFilters,
 int maxResults,
 List<QueryOrderingProperty> orderingProperties)

findExternalTasksByQueryCriteria

public List<ExternalTask> findExternalTasksByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)

findExternalTaskIdsByQueryCriteria

public List<String> findExternalTaskIdsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)

findDeploymentIdMappingsByQueryCriteria

public List<ImmutablePair<String,String>> findDeploymentIdMappingsByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)

findExternalTaskCountByQueryCriteria

public long findExternalTaskCountByQueryCriteria(ExternalTaskQueryImpl externalTaskQuery)

selectTopicNamesByQuery

public List<String> selectTopicNamesByQuery(ExternalTaskQueryImpl externalTaskQuery)

updateExternalTaskSuspensionState

protected void updateExternalTaskSuspensionState(String processInstanceId,
 String processDefinitionId,
 String processDefinitionKey,
 SuspensionState suspensionState)

updateExternalTaskSuspensionStateByProcessInstanceId

public void updateExternalTaskSuspensionStateByProcessInstanceId(String processInstanceId,
 SuspensionState suspensionState)

updateExternalTaskSuspensionStateByProcessDefinitionId

public void updateExternalTaskSuspensionStateByProcessDefinitionId(String processDefinitionId,
 SuspensionState suspensionState)

updateExternalTaskSuspensionStateByProcessDefinitionKey

public void updateExternalTaskSuspensionStateByProcessDefinitionKey(String processDefinitionKey,
 SuspensionState suspensionState)

updateExternalTaskSuspensionStateByProcessDefinitionKeyAndTenantId

public void updateExternalTaskSuspensionStateByProcessDefinitionKeyAndTenantId(String processDefinitionKey,
 String processDefinitionTenantId,
 SuspensionState suspensionState)

configureQuery

protected void configureQuery(ExternalTaskQueryImpl query)

configureQuery

protected void configureQuery(ListQueryParameterObject parameter)

configureParameterizedQuery

protected ListQueryParameterObject configureParameterizedQuery(Object parameter)

shouldApplyOrdering

protected boolean shouldApplyOrdering(boolean usePriority,
 boolean useCreateTime)

useCreateTime

protected boolean useCreateTime(List<QueryOrderingProperty> orderingProperties)

fireExternalTaskAvailableEvent

public void fireExternalTaskAvailableEvent()