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

Field Summary

Fields

Modifier and Type	Field	Description
static QueryOrderingProperty	EXT_TASK_PRIORITY_ORDERING_PROPERTY

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, boolean usePriority)
List<String>	selectTopicNamesByQuery(ExternalTaskQueryImpl externalTaskQuery)
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)

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

Field Detail

EXT_TASK_PRIORITY_ORDERING_PROPERTY

public static QueryOrderingProperty EXT_TASK_PRIORITY_ORDERING_PROPERTY

Constructor Detail

ExternalTaskManager

public ExternalTaskManager()

Method Detail

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,
                                                             boolean usePriority)

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)

fireExternalTaskAvailableEvent

public void fireExternalTaskAvailableEvent()