Class ExternalTaskManager

  • All Implemented Interfaces:
    Session

    public class ExternalTaskManager
    extends AbstractManager
    Author:
    Thorben Lindhauer
    • 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​(java.lang.String id)
      • 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)
      • 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)
      • configureParameterizedQuery

        protected ListQueryParameterObject configureParameterizedQuery​(java.lang.Object parameter)
      • fireExternalTaskAvailableEvent

        public void fireExternalTaskAvailableEvent()