Package org.flowable.job.service.impl
Class SuspendedJobQueryImpl
java.lang.Object
org.flowable.common.engine.impl.db.ListQueryParameterObject
org.flowable.common.engine.impl.query.AbstractQuery<SuspendedJobQuery,Job>
org.flowable.job.service.impl.SuspendedJobQueryImpl
- All Implemented Interfaces:
Serializable
,Query<SuspendedJobQuery,
,Job> Command<Object>
,BaseJobQuery<SuspendedJobQuery,
,Job> SuspendedJobQuery
public class SuspendedJobQueryImpl
extends AbstractQuery<SuspendedJobQuery,Job>
implements SuspendedJobQuery, Serializable
- Author:
- Joram Barrez, Tijs Rademakers
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from class org.flowable.common.engine.impl.db.ListQueryParameterObject
ListQueryParameterObject.OrderBy, ListQueryParameterObject.ResultType
Nested classes/interfaces inherited from interface org.flowable.common.engine.api.query.Query
Query.NullHandlingOnOrder
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected String
protected String
protected String
protected String
protected Date
protected Date
protected Date
protected Date
protected String
protected String
protected String
protected boolean
protected String
protected String
protected Collection<String>
protected String
protected Collection<String>
protected JobServiceConfiguration
protected boolean
protected boolean
protected boolean
protected boolean
protected String
protected String
protected String
protected boolean
protected String
protected String
protected String
protected String
protected String
protected String
protected boolean
protected boolean
protected boolean
protected boolean
protected boolean
Fields inherited from class org.flowable.common.engine.impl.query.AbstractQuery
commandContext, commandExecutor
Fields inherited from class org.flowable.common.engine.impl.db.ListQueryParameterObject
databaseType, DEFAULT_ORDER_BY, defaultOrderBy, firstResult, maxResults, nullHandlingColumn, nullHandlingOnOrder, orderByCollection, orderProperty, parameter, resultType, SORTORDER_ASC, SORTORDER_DESC
-
Constructor Summary
ConstructorsConstructorDescriptionSuspendedJobQueryImpl
(CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration) SuspendedJobQueryImpl
(CommandExecutor commandExecutor, JobServiceConfiguration jobServiceConfiguration) -
Method Summary
Modifier and TypeMethodDescriptioncaseDefinitionId
(String caseDefinitionId) Only select jobs for the given case definition.caseDefinitionKey
(String caseDefinitionKey) Only select tasks for the given case definition key.caseInstanceId
(String caseInstanceId) Only select jobs for the given case instance.Only select jobs which exist for the given categorycategoryLike
(String categoryLike) Only select jobs like for the given category valuecorrelationId
(String correlationId) Only select jobs with the given correlationId.duedateHigherThan
(Date date) Only select jobs where the duedate is higher then the given date.duedateHigherThen
(Date date) duedateLowerThan
(Date date) Only select jobs where the duedate is lower than the given date.duedateLowerThen
(Date date) duedateLowerThenOrEquals
(Date date) Only select jobs which exist for the given element idelementName
(String elementName) Only select jobs which exist for the given element nameexceptionMessage
(String exceptionMessage) Only select jobs that failed due to an exception with the given message.Only select jobs which are executable, ie.long
executeCount
(CommandContext commandContext) executeList
(CommandContext commandContext) Executes the actual query to retrieve the list of results.executionId
(String executionId) Only select jobs which exist for the given executionOnly select external worker jobs.boolean
getId()
getNow()
boolean
handlerType
(String handlerType) Select jobs which have given job handler typehandlerTypes
(Collection<String> handlerTypes) Select jobs which have one of the given job handler typeboolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
boolean
Only select jobs with the given idjobIds
(Collection<String> jobIds) Only select jobs with the given ids.jobTenantId
(String tenantId) Only select jobs that have the given tenant id.jobTenantIdLike
(String tenantIdLike) Only select jobs with a tenant id like the given one.Only select jobs that do not have a tenant id.messages()
Only select jobs that are messages.Only select jobs which have no retries leftOrder by execution id (needs to be followed byQuery.asc()
orQuery.desc()
).Order by create time (needs to be followed byQuery.asc()
orQuery.desc()
).Order by duedate (needs to be followed byQuery.asc()
orQuery.desc()
).Order by job id (needs to be followed byQuery.asc()
orQuery.desc()
).Order by retries (needs to be followed byQuery.asc()
orQuery.desc()
).Order by process instance id (needs to be followed byQuery.asc()
orQuery.desc()
).Order by tenant id (needs to be followed byQuery.asc()
orQuery.desc()
).planItemInstanceId
(String planItemInstanceId) Only select jobs for the given plan item instance.processDefinitionId
(String processDefinitionId) Only select jobs which exist for the given process definition idprocessDefinitionKey
(String processDefinitionKey) Only select jobs which exist for the given process definition keyprocessInstanceId
(String processInstanceId) Only select jobs which exist for the given process instance.scopeDefinitionId
(String scopeDefinitionId) Only select tasks for the given scope definition identifier.Only select tasks for the given scope identifier.Only select tasks for the given scope type.subScopeId
(String subScopeId) Only select tasks for the given sub scope identifier.timers()
Only select jobs that are timers.Only select jobs that failed due to an exception.Only select jobs without a process instance id value.Only select jobs without a scope id value.Only return jobs that do not have a scope type.Only select jobs which have retries leftMethods inherited from class org.flowable.common.engine.impl.query.AbstractQuery
asc, checkQueryOk, count, desc, direction, execute, executeSingleResult, list, listPage, orderBy, orderBy, setCommandExecutor, singleResult
Methods inherited from class org.flowable.common.engine.impl.db.ListQueryParameterObject
addOrder, buildOrderBy, getDatabaseType, getFirstResult, getFirstRow, getLastRow, getMaxResults, getNullHandlingColumn, getOrderBy, getOrderByCollectionSafe, getOrderByForWindow, getOuterJoinOrderBy, getParameter, hasOrderBy, hasOrderByForColumn, isNeedsPaging, mapOrderByToSql, setDatabaseType, setFirstResult, setMaxResults, setNullHandlingColumn, setParameter
-
Field Details
-
jobServiceConfiguration
-
id
-
jobIds
-
processInstanceId
-
withoutProcessInstanceId
protected boolean withoutProcessInstanceId -
executionId
-
handlerType
-
handlerTypes
-
processDefinitionId
-
processDefinitionKey
-
category
-
categoryLike
-
elementId
-
elementName
-
scopeId
-
withoutScopeId
protected boolean withoutScopeId -
subScopeId
-
scopeType
-
withoutScopeType
protected boolean withoutScopeType -
scopeDefinitionId
-
caseDefinitionKey
-
correlationId
-
executable
protected boolean executable -
onlyTimers
protected boolean onlyTimers -
onlyMessages
protected boolean onlyMessages -
onlyExternalWorkers
protected boolean onlyExternalWorkers -
duedateHigherThan
-
duedateLowerThan
-
duedateHigherThanOrEqual
-
duedateLowerThanOrEqual
-
withException
protected boolean withException -
exceptionMessage
-
tenantId
-
tenantIdLike
-
withoutTenantId
protected boolean withoutTenantId -
retriesLeft
protected boolean retriesLeft -
noRetriesLeft
protected boolean noRetriesLeft
-
-
Constructor Details
-
SuspendedJobQueryImpl
public SuspendedJobQueryImpl() -
SuspendedJobQueryImpl
public SuspendedJobQueryImpl(CommandContext commandContext, JobServiceConfiguration jobServiceConfiguration) -
SuspendedJobQueryImpl
public SuspendedJobQueryImpl(CommandExecutor commandExecutor, JobServiceConfiguration jobServiceConfiguration)
-
-
Method Details
-
jobId
Description copied from interface:BaseJobQuery
Only select jobs with the given id- Specified by:
jobId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
jobIds
Description copied from interface:BaseJobQuery
Only select jobs with the given ids. If you use jobId(String
jobId) this filter gets ignored.- Specified by:
jobIds
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
processInstanceId
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given process instance.- Specified by:
processInstanceId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
withoutProcessInstanceId
Description copied from interface:BaseJobQuery
Only select jobs without a process instance id value.- Specified by:
withoutProcessInstanceId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
processDefinitionId
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given process definition id- Specified by:
processDefinitionId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
processDefinitionKey
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given process definition key- Specified by:
processDefinitionKey
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
category
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given category- Specified by:
category
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
categoryLike
Description copied from interface:BaseJobQuery
Only select jobs like for the given category value- Specified by:
categoryLike
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
elementId
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given element id- Specified by:
elementId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
elementName
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given element name- Specified by:
elementName
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
scopeId
Description copied from interface:BaseJobQuery
Only select tasks for the given scope identifier.- Specified by:
scopeId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
withoutScopeId
Description copied from interface:BaseJobQuery
Only select jobs without a scope id value.- Specified by:
withoutScopeId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
subScopeId
Description copied from interface:BaseJobQuery
Only select tasks for the given sub scope identifier.- Specified by:
subScopeId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
scopeType
Description copied from interface:BaseJobQuery
Only select tasks for the given scope type.- Specified by:
scopeType
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
withoutScopeType
Description copied from interface:BaseJobQuery
Only return jobs that do not have a scope type.- Specified by:
withoutScopeType
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
scopeDefinitionId
Description copied from interface:BaseJobQuery
Only select tasks for the given scope definition identifier.- Specified by:
scopeDefinitionId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
caseInstanceId
Description copied from interface:BaseJobQuery
Only select jobs for the given case instance.- Specified by:
caseInstanceId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
caseDefinitionId
Description copied from interface:BaseJobQuery
Only select jobs for the given case definition.- Specified by:
caseDefinitionId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
caseDefinitionKey
Description copied from interface:BaseJobQuery
Only select tasks for the given case definition key.- Specified by:
caseDefinitionKey
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
planItemInstanceId
Description copied from interface:BaseJobQuery
Only select jobs for the given plan item instance.- Specified by:
planItemInstanceId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
correlationId
Description copied from interface:BaseJobQuery
Only select jobs with the given correlationId.- Specified by:
correlationId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
executionId
Description copied from interface:BaseJobQuery
Only select jobs which exist for the given execution- Specified by:
executionId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
handlerType
Description copied from interface:BaseJobQuery
Select jobs which have given job handler type- Specified by:
handlerType
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
handlerTypes
Description copied from interface:BaseJobQuery
Select jobs which have one of the given job handler type- Specified by:
handlerTypes
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
withRetriesLeft
Description copied from interface:SuspendedJobQuery
Only select jobs which have retries left- Specified by:
withRetriesLeft
in interfaceSuspendedJobQuery
-
executable
Description copied from interface:SuspendedJobQuery
Only select jobs which are executable, ie. retries > 0 and duedate is null or duedate is in the past- Specified by:
executable
in interfaceSuspendedJobQuery
-
timers
Description copied from interface:SuspendedJobQuery
Only select jobs that are timers. Cannot be used together withSuspendedJobQuery.messages()
orSuspendedJobQuery.externalWorkers()
- Specified by:
timers
in interfaceSuspendedJobQuery
-
messages
Description copied from interface:SuspendedJobQuery
Only select jobs that are messages. Cannot be used together withSuspendedJobQuery.timers()
orSuspendedJobQuery.externalWorkers()
- Specified by:
messages
in interfaceSuspendedJobQuery
-
externalWorkers
Description copied from interface:SuspendedJobQuery
Only select external worker jobs. Cannot be used together withSuspendedJobQuery.timers()
orSuspendedJobQuery.messages()
- Specified by:
externalWorkers
in interfaceSuspendedJobQuery
-
duedateHigherThan
Description copied from interface:BaseJobQuery
Only select jobs where the duedate is higher then the given date.- Specified by:
duedateHigherThan
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
duedateLowerThan
Description copied from interface:BaseJobQuery
Only select jobs where the duedate is lower than the given date.- Specified by:
duedateLowerThan
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
duedateHigherThen
-
duedateHigherThenOrEquals
-
duedateLowerThen
-
duedateLowerThenOrEquals
-
noRetriesLeft
Description copied from interface:SuspendedJobQuery
Only select jobs which have no retries left- Specified by:
noRetriesLeft
in interfaceSuspendedJobQuery
-
withException
Description copied from interface:BaseJobQuery
Only select jobs that failed due to an exception.- Specified by:
withException
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
exceptionMessage
Description copied from interface:BaseJobQuery
Only select jobs that failed due to an exception with the given message.- Specified by:
exceptionMessage
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
jobTenantId
Description copied from interface:BaseJobQuery
Only select jobs that have the given tenant id.- Specified by:
jobTenantId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
jobTenantIdLike
Description copied from interface:BaseJobQuery
Only select jobs with a tenant id like the given one.- Specified by:
jobTenantIdLike
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
jobWithoutTenantId
Description copied from interface:BaseJobQuery
Only select jobs that do not have a tenant id.- Specified by:
jobWithoutTenantId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByJobDuedate
Description copied from interface:BaseJobQuery
Order by duedate (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByJobDuedate
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByJobCreateTime
Description copied from interface:BaseJobQuery
Order by create time (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByJobCreateTime
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByExecutionId
Description copied from interface:BaseJobQuery
Order by execution id (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByExecutionId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByJobId
Description copied from interface:BaseJobQuery
Order by job id (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByJobId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByProcessInstanceId
Description copied from interface:BaseJobQuery
Order by process instance id (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByProcessInstanceId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByJobRetries
Description copied from interface:BaseJobQuery
Order by retries (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByJobRetries
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
orderByTenantId
Description copied from interface:BaseJobQuery
Order by tenant id (needs to be followed byQuery.asc()
orQuery.desc()
).- Specified by:
orderByTenantId
in interfaceBaseJobQuery<SuspendedJobQuery,
Job>
-
executeCount
- Specified by:
executeCount
in classAbstractQuery<SuspendedJobQuery,
Job>
-
executeList
Description copied from class:AbstractQuery
Executes the actual query to retrieve the list of results.- Specified by:
executeList
in classAbstractQuery<SuspendedJobQuery,
Job>
-
getProcessInstanceId
-
isWithoutProcessInstanceId
public boolean isWithoutProcessInstanceId() -
getExecutionId
-
getHandlerType
-
getHandlerTypes
-
getRetriesLeft
public boolean getRetriesLeft() -
getExecutable
public boolean getExecutable() -
getNow
-
isWithException
public boolean isWithException() -
getExceptionMessage
-
getTenantId
-
getTenantIdLike
-
isWithoutTenantId
public boolean isWithoutTenantId() -
getId
-
getProcessDefinitionId
-
getProcessDefinitionKey
-
getCategory
-
getCategoryLike
-
getElementId
-
getElementName
-
getScopeId
-
isWithoutScopeId
public boolean isWithoutScopeId() -
getSubScopeId
-
getScopeType
-
isWithoutScopeType
public boolean isWithoutScopeType() -
getScopeDefinitionId
-
getCaseDefinitionKey
-
getCorrelationId
-
isOnlyTimers
public boolean isOnlyTimers() -
isOnlyMessages
public boolean isOnlyMessages() -
isOnlyExternalWorkers
public boolean isOnlyExternalWorkers() -
getDuedateHigherThan
-
getDuedateLowerThan
-
getDuedateHigherThanOrEqual
-
getDuedateLowerThanOrEqual
-
isNoRetriesLeft
public boolean isNoRetriesLeft() -
isExecutable
public boolean isExecutable() -
isRetriesLeft
public boolean isRetriesLeft()
-