Package org.camunda.bpm.engine.impl

Class ExternalTaskQueryImpl

java.lang.Object

org.camunda.bpm.engine.impl.db.ListQueryParameterObject

org.camunda.bpm.engine.impl.AbstractQuery<ExternalTaskQuery,ExternalTask>

org.camunda.bpm.engine.impl.ExternalTaskQueryImpl

All Implemented Interfaces:

Serializable, ExternalTaskQuery, Command<Object>, Query<ExternalTaskQuery,ExternalTask>

public class ExternalTaskQueryImpl
extends AbstractQuery<ExternalTaskQuery,ExternalTask>
implements ExternalTaskQuery

Author:

Thorben Lindhauer, Christopher Zell

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.camunda.bpm.engine.impl.AbstractQuery

AbstractQuery.ResultType

Field Summary

Fields

Modifier and Type	Field	Description
protected String	activityId
protected String[]	activityIdIn
protected String	executionId
protected String	externalTaskId
protected Set<String>	externalTaskIds
protected Boolean	locked
protected Date	lockExpirationAfter
protected Date	lockExpirationBefore
protected Boolean	notLocked
protected Long	priorityHigherThanOrEquals
protected Long	priorityLowerThanOrEquals
protected String	processDefinitionId
protected String	processInstanceId
protected String[]	processInstanceIdIn
protected Boolean	retriesLeft
protected SuspensionState	suspensionState
protected String[]	tenantIds
protected String	topicName
protected String	workerId

Fields inherited from class org.camunda.bpm.engine.impl.AbstractQuery

commandExecutor, expressions, maxResultsLimitEnabled, resultType, SORTORDER_ASC, SORTORDER_DESC, validators

Fields inherited from class org.camunda.bpm.engine.impl.db.ListQueryParameterObject

authCheck, databaseType, firstResult, maxResults, orderingProperties, parameter, tenantCheck

Constructor Summary

Constructors

Constructor	Description
ExternalTaskQueryImpl()
ExternalTaskQueryImpl(CommandExecutor commandExecutor)

Method Summary

Modifier and Type	Method	Description
ExternalTaskQuery	active()	Only select external tasks that are currently not suspended
ExternalTaskQuery	activityId(String activityId)	Only select external tasks that belong to an instance of the given activity
ExternalTaskQuery	activityIdIn(String... activityIdIn)	Only select external tasks that belong to an instances of the given activities.
long	executeCount(CommandContext commandContext)
List<ImmutablePair<String,String>>	executeDeploymentIdMappingsList(CommandContext commandContext)
List<String>	executeIdsList(CommandContext commandContext)
List<ExternalTask>	executeList(CommandContext commandContext, Page page)	Executes the actual query to retrieve the list of results.
ExternalTaskQuery	executionId(String executionId)	Only select external tasks created in the context of the given execution
ExternalTaskQuery	externalTaskId(String externalTaskId)	Only select the external task with the given id
ExternalTaskQuery	externalTaskIdIn(Set<String> externalTaskIds)	Only select external tasks with any of the given ids
String	getActivityId()
String	getExecutionId()
String	getExternalTaskId()
Boolean	getLocked()
Date	getLockExpirationAfter()
Date	getLockExpirationBefore()
Boolean	getNotLocked()
Date	getNow()
String	getProcessDefinitionId()
String	getProcessInstanceId()
Boolean	getRetriesLeft()
SuspensionState	getSuspensionState()
String	getTopicName()
String	getWorkerId()
protected boolean	hasExcludingConditions()	Whether or not the query has excluding conditions.
ExternalTaskQuery	locked()	Only select external tasks that are currently locked, i.e.
ExternalTaskQuery	lockExpirationAfter(Date lockExpirationDate)	Only select external tasks that have a lock expiring after the given date
ExternalTaskQuery	lockExpirationBefore(Date lockExpirationDate)	Only select external tasks that have a lock expiring before the given date
ExternalTaskQuery	noRetriesLeft()	Only select external tasks that have retries = 0
ExternalTaskQuery	notLocked()	Only select external tasks that are not currently locked, i.e.
ExternalTaskQuery	orderById()	Order by external task id (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	orderByLockExpirationTime()	Order by lock expiration time (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	orderByPriority()	Order by priority (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	orderByProcessDefinitionId()	Order by process definition id (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	orderByProcessDefinitionKey()	Order by process definition key (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	orderByProcessInstanceId()	Order by process instance id (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	orderByTenantId()	Order by tenant id (needs to be followed by Query.asc() or Query.desc()).
ExternalTaskQuery	priorityHigherThanOrEquals(long priority)	Only select external tasks with a priority that is higher than or equal to the given priority.
ExternalTaskQuery	priorityLowerThanOrEquals(long priority)	Only select external tasks with a priority that is lower than or equal to the given priority.
ExternalTaskQuery	processDefinitionId(String processDefinitionId)	Only select external tasks that belong to an instance of the given process definition
ExternalTaskQuery	processInstanceId(String processInstanceId)	Only select external tasks created in the context of the given process instance
ExternalTaskQuery	processInstanceIdIn(String... processInstanceIdIn)	Only select external tasks created in the context of the given process instances
ExternalTaskQuery	suspended()	Only select external tasks that are currently suspended
ExternalTaskQuery	tenantIdIn(String... tenantIds)	Only select external tasks that belong to one of the given tenant ids.
ExternalTaskQuery	topicName(String topicName)	Only select external tasks of the given topic
ExternalTaskQuery	withRetriesLeft()	Only select external tasks that have retries > 0
ExternalTaskQuery	workerId(String workerId)	Only select external tasks that was most recently locked by the given worker

Methods inherited from class org.camunda.bpm.engine.impl.AbstractQuery

addExpression, addValidator, asc, checkMaxResultsLimit, checkQueryOk, count, desc, direction, disableMaxResultsLimit, enableMaxResultsLimit, evaluateExpressions, evaluateExpressionsAndExecuteCount, evaluateExpressionsAndExecuteDeploymentIdMappingsList, evaluateExpressionsAndExecuteIdsList, evaluateExpressionsAndExecuteList, execute, executeResult, executeSingleResult, extend, getExpressions, getMethod, list, listDeploymentIdMappings, listIds, listPage, mergeExpressions, mergeOrdering, orderBy, orderBy, removeValidator, setCommandExecutor, setExpressions, singleResult, unlimitedList, validate, validate

Methods inherited from class org.camunda.bpm.engine.impl.db.ListQueryParameterObject

getAuthCheck, getDatabaseType, getFirstResult, getFirstRow, getLastRow, getMaxResults, getOrderingProperties, getParameter, getTenantCheck, setAuthCheck, setDatabaseType, setFirstResult, setMaxResults, setOrderingProperties, setParameter, setTenantCheck

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.camunda.bpm.engine.impl.interceptor.Command

isRetryable

Methods inherited from interface org.camunda.bpm.engine.query.Query

asc, count, desc, list, listPage, singleResult, unlimitedList

Field Details

externalTaskId

protected String externalTaskId

externalTaskIds

protected Set<String> externalTaskIds

workerId

protected String workerId

lockExpirationBefore

protected Date lockExpirationBefore

lockExpirationAfter

protected Date lockExpirationAfter

topicName

protected String topicName

locked

protected Boolean locked

notLocked

protected Boolean notLocked

executionId

protected String executionId

processInstanceId

protected String processInstanceId

processInstanceIdIn

protected String[] processInstanceIdIn

processDefinitionId

protected String processDefinitionId

activityId

protected String activityId

activityIdIn

protected String[] activityIdIn

suspensionState

protected SuspensionState suspensionState

priorityHigherThanOrEquals

protected Long priorityHigherThanOrEquals

priorityLowerThanOrEquals

protected Long priorityLowerThanOrEquals

retriesLeft

protected Boolean retriesLeft

tenantIds

protected String[] tenantIds

Constructor Details

ExternalTaskQueryImpl

public ExternalTaskQueryImpl()

ExternalTaskQueryImpl

public ExternalTaskQueryImpl(CommandExecutor commandExecutor)

Method Details

externalTaskId

public ExternalTaskQuery externalTaskId(String externalTaskId)

Description copied from interface: ExternalTaskQuery

Only select the external task with the given id

Specified by:

externalTaskId in interface ExternalTaskQuery

externalTaskIdIn

public ExternalTaskQuery externalTaskIdIn(Set<String> externalTaskIds)

Description copied from interface: ExternalTaskQuery

Only select external tasks with any of the given ids

Specified by:

externalTaskIdIn in interface ExternalTaskQuery

workerId

public ExternalTaskQuery workerId(String workerId)

Description copied from interface: ExternalTaskQuery

Only select external tasks that was most recently locked by the given worker

Specified by:

workerId in interface ExternalTaskQuery

lockExpirationBefore

public ExternalTaskQuery lockExpirationBefore(Date lockExpirationDate)

Description copied from interface: ExternalTaskQuery

Only select external tasks that have a lock expiring before the given date

Specified by:

lockExpirationBefore in interface ExternalTaskQuery

lockExpirationAfter

public ExternalTaskQuery lockExpirationAfter(Date lockExpirationDate)

Description copied from interface: ExternalTaskQuery

Only select external tasks that have a lock expiring after the given date

Specified by:

lockExpirationAfter in interface ExternalTaskQuery

topicName

public ExternalTaskQuery topicName(String topicName)

Description copied from interface: ExternalTaskQuery

Only select external tasks of the given topic

Specified by:

topicName in interface ExternalTaskQuery

locked

public ExternalTaskQuery locked()

Description copied from interface: ExternalTaskQuery

Only select external tasks that are currently locked, i.e. that have a lock expiration time that is in the future

Specified by:

locked in interface ExternalTaskQuery

notLocked

public ExternalTaskQuery notLocked()

Description copied from interface: ExternalTaskQuery

Only select external tasks that are not currently locked, i.e. that have no lock expiration time or one that is overdue

Specified by:

notLocked in interface ExternalTaskQuery

executionId

public ExternalTaskQuery executionId(String executionId)

Description copied from interface: ExternalTaskQuery

Only select external tasks created in the context of the given execution

Specified by:

executionId in interface ExternalTaskQuery

processInstanceId

public ExternalTaskQuery processInstanceId(String processInstanceId)

Description copied from interface: ExternalTaskQuery

Only select external tasks created in the context of the given process instance

Specified by:

processInstanceId in interface ExternalTaskQuery

processInstanceIdIn

public ExternalTaskQuery processInstanceIdIn(String... processInstanceIdIn)

Description copied from interface: ExternalTaskQuery

Only select external tasks created in the context of the given process instances

Specified by:

processInstanceIdIn in interface ExternalTaskQuery

processDefinitionId

public ExternalTaskQuery processDefinitionId(String processDefinitionId)

Description copied from interface: ExternalTaskQuery

Only select external tasks that belong to an instance of the given process definition

Specified by:

processDefinitionId in interface ExternalTaskQuery

activityId

public ExternalTaskQuery activityId(String activityId)

Description copied from interface: ExternalTaskQuery

Only select external tasks that belong to an instance of the given activity

Specified by:

activityId in interface ExternalTaskQuery

activityIdIn

public ExternalTaskQuery activityIdIn(String... activityIdIn)

Description copied from interface: ExternalTaskQuery

Only select external tasks that belong to an instances of the given activities.

Specified by:

activityIdIn in interface ExternalTaskQuery

priorityHigherThanOrEquals

public ExternalTaskQuery priorityHigherThanOrEquals(long priority)

Description copied from interface: ExternalTaskQuery

Only select external tasks with a priority that is higher than or equal to the given priority.

Specified by:

priorityHigherThanOrEquals in interface ExternalTaskQuery

Parameters:

priority - the priority which is used for the query

Returns:

the builded external task query

priorityLowerThanOrEquals

public ExternalTaskQuery priorityLowerThanOrEquals(long priority)

Description copied from interface: ExternalTaskQuery

Only select external tasks with a priority that is lower than or equal to the given priority.

Specified by:

priorityLowerThanOrEquals in interface ExternalTaskQuery

Parameters:

priority - the priority which is used for the query

Returns:

the builded external task query

suspended

public ExternalTaskQuery suspended()

Description copied from interface: ExternalTaskQuery

Only select external tasks that are currently suspended

Specified by:

suspended in interface ExternalTaskQuery

active

public ExternalTaskQuery active()

Description copied from interface: ExternalTaskQuery

Only select external tasks that are currently not suspended

Specified by:

active in interface ExternalTaskQuery

withRetriesLeft

public ExternalTaskQuery withRetriesLeft()

Description copied from interface: ExternalTaskQuery

Only select external tasks that have retries > 0

Specified by:

withRetriesLeft in interface ExternalTaskQuery

noRetriesLeft

public ExternalTaskQuery noRetriesLeft()

Description copied from interface: ExternalTaskQuery

Only select external tasks that have retries = 0

Specified by:

noRetriesLeft in interface ExternalTaskQuery

hasExcludingConditions

protected boolean hasExcludingConditions()

Description copied from class: AbstractQuery

Whether or not the query has excluding conditions. If the query has excluding conditions, (e.g. task due date before and after are excluding), the SQL query is avoided and a default result is returned. The returned result is the same as if the SQL was executed and there were no entries.

Overrides:

hasExcludingConditions in class AbstractQuery<ExternalTaskQuery,ExternalTask>

Returns:

true if the query does have excluding conditions, false otherwise

tenantIdIn

public ExternalTaskQuery tenantIdIn(String... tenantIds)

Description copied from interface: ExternalTaskQuery

Only select external tasks that belong to one of the given tenant ids.

Specified by:

tenantIdIn in interface ExternalTaskQuery

orderById

public ExternalTaskQuery orderById()

Description copied from interface: ExternalTaskQuery

Order by external task id (needs to be followed by Query.asc() or Query.desc()).

Specified by:

orderById in interface ExternalTaskQuery

orderByLockExpirationTime

public ExternalTaskQuery orderByLockExpirationTime()

Description copied from interface: ExternalTaskQuery

Order by lock expiration time (needs to be followed by Query.asc() or Query.desc()). Ordering of tasks with no lock expiration time is database-dependent.

Specified by:

orderByLockExpirationTime in interface ExternalTaskQuery

orderByProcessInstanceId

public ExternalTaskQuery orderByProcessInstanceId()

Description copied from interface: ExternalTaskQuery

Order by process instance id (needs to be followed by Query.asc() or Query.desc()).

Specified by:

orderByProcessInstanceId in interface ExternalTaskQuery

orderByProcessDefinitionId

public ExternalTaskQuery orderByProcessDefinitionId()

Description copied from interface: ExternalTaskQuery

Order by process definition id (needs to be followed by Query.asc() or Query.desc()).

Specified by:

orderByProcessDefinitionId in interface ExternalTaskQuery

orderByProcessDefinitionKey

public ExternalTaskQuery orderByProcessDefinitionKey()

Description copied from interface: ExternalTaskQuery

Order by process definition key (needs to be followed by Query.asc() or Query.desc()).

Specified by:

orderByProcessDefinitionKey in interface ExternalTaskQuery

orderByTenantId

public ExternalTaskQuery orderByTenantId()

Description copied from interface: ExternalTaskQuery

Order by tenant id (needs to be followed by Query.asc() or Query.desc()). Note that the ordering of external tasks without tenant id is database-specific.

Specified by:

orderByTenantId in interface ExternalTaskQuery

orderByPriority

public ExternalTaskQuery orderByPriority()

Description copied from interface: ExternalTaskQuery

Order by priority (needs to be followed by Query.asc() or Query.desc()).

Specified by:

orderByPriority in interface ExternalTaskQuery

executeCount

public long executeCount(CommandContext commandContext)

Specified by:

executeCount in class AbstractQuery<ExternalTaskQuery,ExternalTask>

executeList

public List<ExternalTask> executeList(CommandContext commandContext,
 Page page)

Description copied from class: AbstractQuery

Executes the actual query to retrieve the list of results.

Specified by:

executeList in class AbstractQuery<ExternalTaskQuery,ExternalTask>

page - used if the results must be paged. If null, no paging will be applied.

executeIdsList

public List<String> executeIdsList(CommandContext commandContext)

Overrides:

executeIdsList in class AbstractQuery<ExternalTaskQuery,ExternalTask>

executeDeploymentIdMappingsList

public List<ImmutablePair<String,String>> executeDeploymentIdMappingsList(CommandContext commandContext)

Overrides:

executeDeploymentIdMappingsList in class AbstractQuery<ExternalTaskQuery,ExternalTask>

getExternalTaskId

public String getExternalTaskId()

getWorkerId

public String getWorkerId()

getLockExpirationBefore

public Date getLockExpirationBefore()

getLockExpirationAfter

public Date getLockExpirationAfter()

getTopicName

public String getTopicName()

getLocked

public Boolean getLocked()

getNotLocked

public Boolean getNotLocked()

getExecutionId

public String getExecutionId()

getProcessInstanceId

public String getProcessInstanceId()

getProcessDefinitionId

public String getProcessDefinitionId()

getActivityId

public String getActivityId()

getSuspensionState

public SuspensionState getSuspensionState()

getRetriesLeft

public Boolean getRetriesLeft()

getNow

public Date getNow()