Interface ManagementService
- All Known Implementing Classes:
ManagementServiceImpl
- Author:
- Tom Baeyens, Joram Barrez, Falko Menge, Thorben Lindhauer
-
Method Summary
Modifier and TypeMethodDescriptionvoidactivateBatchById(String batchId) Activates theBatchwith the given id immediately.voidactivateJobById(String jobId) Activates theJobwith the given id.voidactivateJobByJobDefinitionId(String jobDefinitionId) Activates allJobs of the provided job definition id.voidactivateJobByProcessDefinitionId(String processDefinitionId) Activates allJobs of the provided process definition id.voidactivateJobByProcessDefinitionKey(String processDefinitionKey) ActivatesJobs of the provided process definition key.voidactivateJobByProcessInstanceId(String processInstanceId) Activates allJobs of the provided process instance id.voidactivateJobDefinitionById(String jobDefinitionId) Activates theJobDefinitionwith the given id immediately.voidactivateJobDefinitionById(String jobDefinitionId, boolean activateJobs) Activates theJobDefinitionwith the given id immediately.voidactivateJobDefinitionById(String jobDefinitionId, boolean activateJobs, Date activationDate) Activates theJobDefinitionwith the given id.voidactivateJobDefinitionByProcessDefinitionId(String processDefinitionId) Activates allJobDefinitions of the provided process definition id immediately.voidactivateJobDefinitionByProcessDefinitionId(String processDefinitionId, boolean activateJobs) Activates allJobDefinitions of the provided process definition id immediately.voidactivateJobDefinitionByProcessDefinitionId(String processDefinitionId, boolean activateJobs, Date activationDate) Activates allJobDefinitions of the provided process definition id.voidactivateJobDefinitionByProcessDefinitionKey(String processDefinitionKey) Activates allJobDefinitions of the provided process definition key immediately.voidactivateJobDefinitionByProcessDefinitionKey(String processDefinitionKey, boolean activateJobs) Activates allJobDefinitions of the provided process definition key immediately.voidactivateJobDefinitionByProcessDefinitionKey(String processDefinitionKey, boolean activateJobs, Date activationDate) Activates allJobDefinitions of the provided process definition key.voidclearOverridingJobPriorityForJobDefinition(String jobDefinitionId) Clears the job definition's overriding job priority if set.createActivityStatisticsQuery(String processDefinitionId) Query for the number of activity instances aggregated by activities of a single process definition.Creates a query to search forBatchinstances.Query for the statistics of the batch execution jobs of a batch.Query for the number of process instances aggregated by deployments.Returns a newJobDefinitionQueryimplementation, that can be used to dynamically query the job definitions.Returns a new JobQuery implementation, that can be used to dynamically query the jobs.Query for the number of process instances aggregated by process definitions.Query for entries of the database schema log.Creates aTablePageQuerythat can be used to fetchTablePagecontaining specific sections of table row data.databaseSchemaUpgrade(Connection connection, String catalog, String schema) programmatic schema update on a given connection returning feedback about what happened Note: will always return an empty stringvoiddeleteBatch(String batchId, boolean cascade) Deletes a batch instance and the corresponding job definitions.voidDelete the job with the provided id.voidDeletes the stored license key.voiddeleteMetrics(Date timestamp) Deletes all metrics events which are older than the specified timestamp.voiddeleteMetrics(Date timestamp, String reporter) Deletes all metrics events which are older than the specified timestamp and reported by the given reporter.voiddeleteProperty(String name) Deletes a property by name.voiddeleteTaskMetrics(Date timestamp) Deletes all task metrics which are older than the specified timestamp.voidexecuteJob(String jobId) Forced synchronous execution of a job (eg.intGet the configured history level for the process engine.getJobExceptionStacktrace(String jobId) Returns the full stacktrace of the exception that occurs when the job with the given id was last executed.Get the stored license key string ornullif no license is set.getProcessApplicationForDeployment(String deploymentId) Get the deployments that are registered the engine's job executor.Get the mapping containing {table name, row count} entries of the database schema.getTableMetaData(String tableName) Gets the metadata (column names, column types, etc.) of a certain table.getTableName(Class<?> entityClass) This method returns the current state of the collected telemetry data.longgetUniqueTaskWorkerCount(Date startTime, Date endTime) Calculates the number of unique task workers based on user task assignees.Checks how sending telemetry data to Camunda is configuredvoidrecalculateJobDuedate(String jobId, boolean creationDateBased) Triggers the recalculation for the job with the provided id.voidregisterDeploymentForJobExecutor(String deploymentId) Register a deployment for the engine's job executor.registerProcessApplication(String deploymentId, ProcessApplicationReference reference) Activate a deployment for a given ProcessApplication.voidForces this engine to commit its pending collected metrics to the database.voidsetJobDuedate(String jobId, Date newDuedate) Sets a new due date for the provided id.voidsetJobDuedate(String jobId, Date newDuedate, boolean cascade) Sets a new due date for the provided id.voidsetJobPriority(String jobId, long priority) Sets a new priority for the job with the provided id.setJobRetries(int retries) Creates a fluent builder to set the number of retries on one or multiplejobs.voidsetJobRetries(String jobId, int retries) Sets the number of retries that a job has left.voidsetJobRetries(List<String> jobIds, int retries) Sets the number of retries that jobs have left.setJobRetriesAsync(List<String> jobIds, int retries) Sets the number of retries that jobs have left asynchronously.setJobRetriesAsync(List<String> jobIds, JobQuery jobQuery, int retries) Sets the number of retries that jobs have left asynchronously.setJobRetriesAsync(List<String> processInstanceIds, ProcessInstanceQuery query, int retries) Sets the number of retries that jobs have left asynchronously.setJobRetriesAsync(List<String> processInstanceIds, ProcessInstanceQuery processInstanceQuery, HistoricProcessInstanceQuery historicProcessInstanceQuery, int retries) Sets the number of retries that jobs have left asynchronously.setJobRetriesAsync(JobQuery jobQuery, int retries) Sets the number of retries that jobs have left asynchronously.voidsetJobRetriesByJobDefinitionId(String jobDefinitionId, int retries) Set the number of retries of all failedjobsof the provided job definition id.setJobRetriesByJobsAsync(int retries) Creates a fluent builder to set the number of retries for one or multiple jobs asynchronously.setJobRetriesByProcessAsync(int retries) Creates a fluent builder to set the number of retries for one or multiple jobs referenced by process asynchronously.voidsetLicenseKey(String licenseKey) Set the license key.voidsetOverridingJobPriorityForJobDefinition(String jobDefinitionId, long priority) Sets an explicit priority for jobs of the given job definition.voidsetOverridingJobPriorityForJobDefinition(String jobDefinitionId, long priority, boolean cascade) Sets an explicit default priority for jobs of the given job definition.voidsetProperty(String name, String value) Set the value for a property.voidsuspendBatchById(String batchId) Suspends theBatchwith the given id immediately.voidsuspendJobById(String jobId) Suspends theJobwith the given id.voidsuspendJobByJobDefinitionId(String jobDefinitionId) Suspends allJobs of the provided job definition id.voidsuspendJobByProcessDefinitionId(String processDefinitionId) Suspends allJobs of the provided process definition id.voidsuspendJobByProcessDefinitionKey(String processDefinitionKey) SuspendsJobs of the provided process definition key.voidsuspendJobByProcessInstanceId(String processInstanceId) Suspends allJobs of the provided process instance id.voidsuspendJobDefinitionById(String jobDefinitionId) Suspends theJobDefinitionwith the given id immediately.voidsuspendJobDefinitionById(String jobDefinitionId, boolean suspendJobs) Suspends theJobDefinitionwith the given id immediately.voidsuspendJobDefinitionById(String jobDefinitionId, boolean suspendJobs, Date suspensionDate) Suspends theJobDefinitionwith the given id.voidsuspendJobDefinitionByProcessDefinitionId(String processDefinitionId) Suspends allJobDefinitionof the provided process definition id immediately.voidsuspendJobDefinitionByProcessDefinitionId(String processDefinitionId, boolean suspendJobs) Suspends allJobDefinitions of the provided process definition id immediately.voidsuspendJobDefinitionByProcessDefinitionId(String processDefinitionId, boolean suspendJobs, Date suspensionDate) Suspends allJobDefinitions of the provided process definition id.voidsuspendJobDefinitionByProcessDefinitionKey(String processDefinitionKey) Suspends allJobDefinitionof the provided process definition key immediately.voidsuspendJobDefinitionByProcessDefinitionKey(String processDefinitionKey, boolean suspendJobs) Suspends allJobDefinitions of the provided process definition key immediately.voidsuspendJobDefinitionByProcessDefinitionKey(String processDefinitionKey, boolean suspendJobs, Date suspensionDate) Suspends allJobDefinitions of the provided process definition key.voidtoggleTelemetry(boolean enabled) Enable/disable sending telemetry data to CamundavoidunregisterDeploymentForJobExecutor(String deploymentId) Unregister a deployment for the engine's job executor.voidunregisterProcessApplication(String deploymentId, boolean removeProcessDefinitionsFromCache) Deactivate a deployment for a given ProcessApplication.voidunregisterProcessApplication(Set<String> deploymentIds, boolean removeProcessDefinitionsFromCache) Deactivate a deployment for a given ProcessApplication.Activate or suspend job definitions using a fluent builder.Activate or suspend jobs using a fluent builder.
-
Method Details
-
registerProcessApplication
ProcessApplicationRegistration registerProcessApplication(String deploymentId, ProcessApplicationReference reference) Activate a deployment for a given ProcessApplication. The effect of this method is twofold:- The process engine will execute atomic operations within the context of that ProcessApplication
- The job executor will start acquiring jobs from that deployment
- Parameters:
deploymentId- the Id of the deployment to activatereference- the reference to the process application- Returns:
- a new
ProcessApplicationRegistration - Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
unregisterProcessApplication
Deactivate a deployment for a given ProcessApplication. This removes the association between the process engine and the process application and optionally removes the associated process definitions from the cache.- Parameters:
deploymentId- the Id of the deployment to deactivateremoveProcessDefinitionsFromCache- indicates whether the process definitions should be removed from the deployment cache- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
unregisterProcessApplication
void unregisterProcessApplication(Set<String> deploymentIds, boolean removeProcessDefinitionsFromCache) Deactivate a deployment for a given ProcessApplication. This removes the association between the process engine and the process application and optionally removes the associated process definitions from the cache.- Parameters:
deploymentIds- the Ids of the deployments to deactivateremoveProcessDefinitionsFromCache- indicates whether the process definitions should be removed from the deployment cache- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
getProcessApplicationForDeployment
- Returns:
- the name of the process application that is currently registered for the given deployment or 'null' if no process application is currently registered.
- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
getTableCount
Get the mapping containing {table name, row count} entries of the database schema.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
getTableName
Gets the table name (including any configured prefix) for an entity likeTask,Executionor the like.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
getTableMetaData
Gets the metadata (column names, column types, etc.) of a certain table. Returns null when no table exists with the given name.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
createTablePageQuery
TablePageQuery createTablePageQuery()Creates aTablePageQuerythat can be used to fetchTablePagecontaining specific sections of table row data.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
createJobQuery
JobQuery createJobQuery()Returns a new JobQuery implementation, that can be used to dynamically query the jobs. -
createJobDefinitionQuery
JobDefinitionQuery createJobDefinitionQuery()Returns a newJobDefinitionQueryimplementation, that can be used to dynamically query the job definitions. -
executeJob
Forced synchronous execution of a job (eg. for administration or testing) The job will be executed, even if the process definition and/or the process instance is in suspended state.- Parameters:
jobId- id of the job to execute, cannot be null.- Throws:
ProcessEngineException- When there is no job with the given id.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
deleteJob
Delete the job with the provided id.- Parameters:
jobId- id of the job to execute, cannot be null.- Throws:
ProcessEngineException- When there is no job with the given id.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
activateJobDefinitionById
Activates the
JobDefinitionwith the given id immediately.Note: All
Jobs of the provided job definition will be not activated.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_DEFINITION.- See Also:
-
activateJobDefinitionByProcessDefinitionId
Activates all
JobDefinitions of the provided process definition id immediately.Note: All
Jobs of the provided job definition will be not activated.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_DEFINITION.- See Also:
-
activateJobDefinitionByProcessDefinitionKey
Activates all
JobDefinitions of the provided process definition key immediately.Note: All
Jobs of the provided job definition will be not activated.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_DEFINITION.- See Also:
-
activateJobDefinitionById
Activates the
JobDefinitionwith the given id immediately.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Parameters:
activateJobs- If true, all theJobs of the provided job definition will be activated too.- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- thrown if the current user does not possess IfactivateJobsistrue, the user must further possess one of the following permissions:- See Also:
-
activateJobDefinitionByProcessDefinitionId
Activates all
JobDefinitions of the provided process definition id immediately.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Parameters:
activateJobs- If true, all theJobs of the provided job definition will be activated too.- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- thrown if the current user does not possess IfactivateJobsistrue, the user must further possess one of the following permissions:- See Also:
-
activateJobDefinitionByProcessDefinitionKey
Activates all
JobDefinitions of the provided process definition key immediately.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Parameters:
activateJobs- If true, all theJobs of the provided job definition will be activated too.- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- thrown if the current user does not possess IfactivateJobsistrue, the user must further possess one of the following permissions:- See Also:
-
activateJobDefinitionById
Activates theJobDefinitionwith the given id.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Parameters:
activateJobs- If true, all theJobs of the provided job definition will be activated too.activationDate- The date on which the job definition will be activated. If null, the job definition is activated immediately. Note: TheJobExecutorneeds to be active to use this!- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- thrown if the current user does not possess IfactivateJobsistrue, the user must further possess one of the following permissions:- See Also:
-
activateJobDefinitionByProcessDefinitionId
void activateJobDefinitionByProcessDefinitionId(String processDefinitionId, boolean activateJobs, Date activationDate) Activates all
JobDefinitions of the provided process definition id.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Parameters:
activateJobs- If true, all theJobs of the provided job definition will be activated too.activationDate- The date on which the job definition will be activated. If null, the job definition is activated immediately. Note: TheJobExecutorneeds to be active to use this!- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- thrown if the current user does not possess IfactivateJobsistrue, the user must further possess one of the following permissions:- See Also:
-
activateJobDefinitionByProcessDefinitionKey
void activateJobDefinitionByProcessDefinitionKey(String processDefinitionKey, boolean activateJobs, Date activationDate) Activates all
JobDefinitions of the provided process definition key.Note: for more complex activate commands use
updateJobDefinitionSuspensionState().- Parameters:
activateJobs- If true, all theJobs of the provided job definition will be activated too.activationDate- The date on which the job definition will be activated. If null, the job definition is activated immediately. Note: TheJobExecutorneeds to be active to use this!- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- thrown if the current user does not possess IfactivateJobsistrue, the user must further possess one of the following permissions:- See Also:
-
suspendJobDefinitionById
Suspends the
JobDefinitionwith the given id immediately.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().Note: All
Jobs of the provided job definition will be not suspended.- Throws:
ProcessEngineException- If no such job definition can be found.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_DEFINITION.- See Also:
-
suspendJobDefinitionByProcessDefinitionId
Suspends all
JobDefinitionof the provided process definition id immediately.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().Note: All
Jobs of the provided job definition will be not suspended.- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_DEFINITION.- See Also:
-
suspendJobDefinitionByProcessDefinitionKey
Suspends all
JobDefinitionof the provided process definition key immediately.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().Note: All
Jobs of the provided job definition will be not suspended.- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_DEFINITION.- See Also:
-
suspendJobDefinitionById
Suspends theJobDefinitionwith the given id immediately.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().- Parameters:
suspendJobs- If true, all theJobs of the provided job definition will be suspended too.- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- thrown if the current user does not possess IfsuspendJobsistrue, the user must further possess one of the following permissions:- See Also:
-
suspendJobDefinitionByProcessDefinitionId
Suspends allJobDefinitions of the provided process definition id immediately.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().- Parameters:
suspendJobs- If true, all theJobs of the provided job definition will be suspended too.- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- thrown if the current user does not possess IfsuspendJobsistrue, the user must further possess one of the following permissions:- See Also:
-
suspendJobDefinitionByProcessDefinitionKey
Suspends allJobDefinitions of the provided process definition key immediately.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().- Parameters:
suspendJobs- If true, all theJobs of the provided job definition will be suspended too.- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- thrown if the current user does not possess IfsuspendJobsistrue, the user must further possess one of the following permissions:- See Also:
-
suspendJobDefinitionById
Suspends theJobDefinitionwith the given id.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().- Parameters:
suspendJobs- If true, all theJobs of the provided job definition will be suspended too.suspensionDate- The date on which the job definition will be suspended. If null, the job definition is suspended immediately. Note: TheJobExecutorneeds to be active to use this!- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- thrown if the current user does not possess IfsuspendJobsistrue, the user must further possess one of the following permissions:- See Also:
-
suspendJobDefinitionByProcessDefinitionId
void suspendJobDefinitionByProcessDefinitionId(String processDefinitionId, boolean suspendJobs, Date suspensionDate) Suspends allJobDefinitions of the provided process definition id.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().- Parameters:
suspendJobs- If true, all theJobs of the provided job definition will be suspended too.suspensionDate- The date on which the job definition will be suspended. If null, the job definition is suspended immediately. Note: TheJobExecutorneeds to be active to use this!- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- thrown if the current user does not possess IfsuspendJobsistrue, the user must further possess one of the following permissions:- See Also:
-
suspendJobDefinitionByProcessDefinitionKey
void suspendJobDefinitionByProcessDefinitionKey(String processDefinitionKey, boolean suspendJobs, Date suspensionDate) Suspends allJobDefinitions of the provided process definition key.Note: for more complex suspend commands use
updateJobDefinitionSuspensionState().- Parameters:
suspendJobs- If true, all theJobs of the provided job definition will be suspended too.suspensionDate- The date on which the job definition will be suspended. If null, the job definition is suspended immediately. Note: TheJobExecutorneeds to be active to use this!- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- thrown if the current user does not possess IfsuspendJobsistrue, the user must further possess one of the following permissions:- See Also:
-
activateJobById
Activates the
Jobwith the given id.Note: for more complex activate commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the job id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
activateJobByJobDefinitionId
Activates all
Jobs of the provided job definition id.Note: for more complex activate commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
activateJobByProcessInstanceId
Activates all
Jobs of the provided process instance id.Note: for more complex activate commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the process instance id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
activateJobByProcessDefinitionId
Activates all
Jobs of the provided process definition id.Note: for more complex activate commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
activateJobByProcessDefinitionKey
Activates
Jobs of the provided process definition key.Note: for more complex activate commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
suspendJobById
Suspends the
Jobwith the given id.Note: for more complex suspend commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the job id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
suspendJobByJobDefinitionId
Suspends all
Jobs of the provided job definition id.Note: for more complex suspend commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the job definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
suspendJobByProcessInstanceId
Suspends all
Jobs of the provided process instance id.Note: for more complex suspend commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the process instance id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
suspendJobByProcessDefinitionId
Suspends all
Jobs of the provided process definition id.Note: for more complex suspend commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the process definition id is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
suspendJobByProcessDefinitionKey
Suspends
Jobs of the provided process definition key.Note: for more complex suspend commands use
updateJobSuspensionState().- Throws:
ProcessEngineException- If the process definition key is equal null.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
updateJobSuspensionState
UpdateJobSuspensionStateSelectBuilder updateJobSuspensionState()Activate or suspend jobs using a fluent builder. Specify the jobs by calling one of the by methods, like byJobId. To update the suspension state callUpdateJobSuspensionStateBuilder.activate()orUpdateJobSuspensionStateBuilder.suspend().- Returns:
- the builder to update the suspension state
-
updateJobDefinitionSuspensionState
UpdateJobDefinitionSuspensionStateSelectBuilder updateJobDefinitionSuspensionState()Activate or suspend job definitions using a fluent builder. Specify the job definitions by calling one of the by methods, like byJobDefinitionId. To update the suspension state callUpdateJobDefinitionSuspensionStateBuilder.activate()orUpdateJobDefinitionSuspensionStateBuilder.suspend().- Returns:
- the builder to update the suspension state
-
setJobRetries
Sets the number of retries that a job has left. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
jobId- id of the job to modify, cannot be null.retries- number of retries.- Throws:
AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEand noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITIONand noProcessInstancePermissions.RETRY_JOBpermission onResources.PROCESS_INSTANCEand noProcessDefinitionPermissions.RETRY_JOBpermission onResources.PROCESS_DEFINITION.
-
setJobRetries
Sets the number of retries that jobs have left. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
jobIds- ids of the jobs to modify, cannot be null.retries- number of retries.- Throws:
BadUserRequestException- if jobIds is nullAuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEand noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITIONand noPermissions#RETRY_JOBpermission onResources.PROCESS_INSTANCEand noPermissions#RETRY_JOBpermission onResources.PROCESS_DEFINITION.
-
setJobRetries
Creates a fluent builder to set the number of retries on one or multiplejobs. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
retries- the number of retries- Returns:
- the builder instance
- See Also:
-
setJobRetriesAsync
Sets the number of retries that jobs have left asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
jobIds- ids of the jobs to modify, cannot be null.retries- number of retries.- Throws:
BadUserRequestException- if jobIds is nullAuthorizationException- If the user has noPermissions.CREATEorBatchPermissions.CREATE_BATCH_SET_JOB_RETRIESpermission onResources.BATCH.
-
setJobRetriesAsync
Sets the number of retries that jobs have left asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
jobQuery- query that identifies which jobs should be modified, cannot be null.retries- number of retries.- Throws:
BadUserRequestException- if jobQuery is nullAuthorizationException- If the user has noPermissions.CREATEorBatchPermissions.CREATE_BATCH_SET_JOB_RETRIESpermission onResources.BATCH.
-
setJobRetriesAsync
Sets the number of retries that jobs have left asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries. Either jobIds or jobQuery has to be provided. If both are provided resulting list of affected jobs will contain jobs matching query as well as jobs defined in the list.- Parameters:
jobIds- ids of the jobs to modify.jobQuery- query that identifies which jobs should be modified.retries- number of retries.- Throws:
BadUserRequestException- if neither jobIds, nor jobQuery is provided or result in empty listAuthorizationException- If the user has noPermissions.CREATEorBatchPermissions.CREATE_BATCH_SET_JOB_RETRIESpermission onResources.BATCH.
-
setJobRetriesAsync
Sets the number of retries that jobs have left asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries. Either jobIds or jobQuery has to be provided. If both are provided resulting list of affected jobs will contain jobs matching query as well as jobs defined in the list.- Parameters:
processInstanceIds- ids of the process instances that for which jobs retries will be setquery- query that identifies process instances with jobs that have to be modifiedretries- number of retries.- Throws:
AuthorizationException- If the user has noPermissions.CREATEorBatchPermissions.CREATE_BATCH_SET_JOB_RETRIESpermission onResources.BATCH.
-
setJobRetriesAsync
Batch setJobRetriesAsync(List<String> processInstanceIds, ProcessInstanceQuery processInstanceQuery, HistoricProcessInstanceQuery historicProcessInstanceQuery, int retries) Sets the number of retries that jobs have left asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries. processInstanceIds, processInstanceQuery or historicProcessInstanceQuery has to be provided. If all are provided, resulting list of affected jobs will contain jobs related to the query as well as jobs related to instances in the list.- Parameters:
processInstanceIds- ids of the process instances that for which jobs retries will be setprocessInstanceQuery- query that identifies process instances with jobs that have to be modifiedhistoricProcessInstanceQuery- historic query that identifies runtime process instances with jobs that have to be modifiedretries- number of retries.- Throws:
AuthorizationException- If the user has noPermissions.CREATEorBatchPermissions.CREATE_BATCH_SET_JOB_RETRIESpermission onResources.BATCH.
-
setJobRetriesByJobsAsync
Creates a fluent builder to set the number of retries for one or multiple jobs asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
retries- number of retries- Returns:
- the builder instance
- See Also:
-
setJobRetriesByProcessAsync
Creates a fluent builder to set the number of retries for one or multiple jobs referenced by process asynchronously. Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be dead and not retried again. In that case, this method can be used to increase the number of retries.- Parameters:
retries- number of retries- Returns:
- the builder instance
- See Also:
-
setJobRetriesByJobDefinitionId
Set the number of retries of all failed
jobsof the provided job definition id.Whenever the JobExecutor fails to execute a job, this value is decremented. When it hits zero, the job is supposed to be failed and not retried again. In that case, this method can be used to increase the number of retries.
Incidentsof the involved failedjobswill not be resolved using this method! When the execution of a job was successful the corresponding incident will be resolved.- Parameters:
jobDefinitionId- id of the job definition, cannot be null.retries- number of retries.- Throws:
AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEand noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITIONand noPermissions#RETRY_JOBpermission onResources.PROCESS_INSTANCEand noPermissions#RETRY_JOBpermission onResources.PROCESS_DEFINITION.
-
setJobDuedate
Sets a new due date for the provided id. When newDuedate is null, the job is executed with the next job executor run.- Parameters:
jobId- id of job to modify, cannot be null.newDuedate- new date for job execution- Throws:
AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
setJobDuedate
Sets a new due date for the provided id. The offset between the old and the new due date can be cascaded to all follow-up jobs. Cascading only works with timer jobs. When newDuedate is null, the job is executed with the next job executor run. In this case the cascade parameter is ignored.- Parameters:
jobId- id of job to modify, cannot be null.newDuedate- new date for job executioncascade- indicate whether follow-up jobs should be affected- Throws:
AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
recalculateJobDuedate
Triggers the recalculation for the job with the provided id.- Parameters:
jobId- id of job to recalculate, must neither be null nor empty.creationDateBased- indicates whether the recalculation should be based on the creation date of the job or the current date- Throws:
AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.PROCESS_INSTANCEor noPermissions.UPDATE_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
setJobPriority
Sets a new priority for the job with the provided id.- Parameters:
jobId- the id of the job to modify, must not be nullpriority- the job's new priority- Throws:
AuthorizationException- thrown if the current user does not possess any of the following permissions- Since:
- 7.4
-
setOverridingJobPriorityForJobDefinition
Sets an explicit priority for jobs of the given job definition. Jobs created after invoking this method receive the given priority. This setting overrides any setting specified in the BPMN 2.0 XML.
The overriding priority can be cleared by using the method
clearOverridingJobPriorityForJobDefinition(String).- Parameters:
jobDefinitionId- the id of the job definition to set the priority forpriority- the priority to set;- Throws:
AuthorizationException- thrown if the current user does not possess any of the following permissions- Since:
- 7.4
-
setOverridingJobPriorityForJobDefinition
void setOverridingJobPriorityForJobDefinition(String jobDefinitionId, long priority, boolean cascade) Sets an explicit default priority for jobs of the given job definition. Jobs created after invoking this method receive the given priority. This setting overrides any setting specified in the BPMN 2.0 XML.
If
cascadeis true, priorities of already existing jobs are updated accordingly.The overriding priority can be cleared by using the method
clearOverridingJobPriorityForJobDefinition(String).- Parameters:
jobDefinitionId- the id of the job definition to set the priority forpriority- the priority to setcascade- if true, priorities of existing jobs of the given definition are changed as well- Throws:
AuthorizationException- thrown if the current user does not possess If cascade istrue, the user must further possess one of the following permissions:- Since:
- 7.4
-
clearOverridingJobPriorityForJobDefinition
Clears the job definition's overriding job priority if set. After invoking this method, new jobs of the given definition receive the priority as specified in the BPMN 2.0 XML or the global default priority.
Existing job instance priorities remain unchanged.
- Parameters:
jobDefinitionId- the id of the job definition for which to clear the overriding priority- Throws:
AuthorizationException- thrown if the current user does not possess any of the following permissions- Since:
- 7.4
-
getJobExceptionStacktrace
Returns the full stacktrace of the exception that occurs when the job with the given id was last executed. Returns null when the job has no exception stacktrace.- Parameters:
jobId- id of the job, cannot be null.- Throws:
ProcessEngineException- When no job exists with the given id.AuthorizationException- If the user has noPermissions.READpermission onResources.PROCESS_INSTANCEor noPermissions.READ_INSTANCEpermission onResources.PROCESS_DEFINITION.
-
getProperties
- Returns:
- a map of all properties.
- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
setProperty
Set the value for a property.- Parameters:
name- the name of the property.value- the new value for the property.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
deleteProperty
Deletes a property by name. If the property does not exist, the request is ignored.- Parameters:
name- the name of the property to delete- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
setLicenseKey
Set the license key.- Parameters:
licenseKey- the license key string.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
getLicenseKey
String getLicenseKey()Get the stored license key string ornullif no license is set.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
deleteLicenseKey
void deleteLicenseKey()Deletes the stored license key. If no license key is set, the request is ignored.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
databaseSchemaUpgrade
programmatic schema update on a given connection returning feedback about what happened Note: will always return an empty string- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
createProcessDefinitionStatisticsQuery
ProcessDefinitionStatisticsQuery createProcessDefinitionStatisticsQuery()Query for the number of process instances aggregated by process definitions. -
createDeploymentStatisticsQuery
DeploymentStatisticsQuery createDeploymentStatisticsQuery()Query for the number of process instances aggregated by deployments. -
createActivityStatisticsQuery
Query for the number of activity instances aggregated by activities of a single process definition.- Throws:
AuthorizationException- If the user has noPermissions.READpermission onResources.PROCESS_DEFINITION.
-
getRegisteredDeployments
Get the deployments that are registered the engine's job executor. This set is only relevant, if the engine configuration propertyjobExecutorDeploymentAwareis set.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
registerDeploymentForJobExecutor
Register a deployment for the engine's job executor. This is required, if the engine configuration propertyjobExecutorDeploymentAwareis set. If set to false, the job executor will execute any job.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
unregisterDeploymentForJobExecutor
Unregister a deployment for the engine's job executor. If the engine configuration propertyjobExecutorDeploymentAwareis set, jobs for the given deployment will no longer get acquired.- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
getHistoryLevel
int getHistoryLevel()Get the configured history level for the process engine.- Returns:
- the history level
- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
createMetricsQuery
MetricsQuery createMetricsQuery()- Returns:
- a new metrics Query.
- Since:
- 7.3
-
deleteMetrics
Deletes all metrics events which are older than the specified timestamp. If the timestamp is null, all metrics will be deleted- Parameters:
timestamp- or null- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.- Since:
- 7.3
-
deleteMetrics
Deletes all metrics events which are older than the specified timestamp and reported by the given reporter. If a parameter is null, all metric events are matched in that regard.- Parameters:
timestamp- or nullreporter- or null- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.- Since:
- 7.4
-
reportDbMetricsNow
void reportDbMetricsNow()Forces this engine to commit its pending collected metrics to the database.- Throws:
ProcessEngineException- if metrics reporting is disabled or the db metrics reporter is deactivated
-
getUniqueTaskWorkerCount
Calculates the number of unique task workers based on user task assignees.- Parameters:
startTime- restrict to data collected after the given date (inclusive), can benullendTime- restrict to data collected before the given date (exclusive), can benull- Returns:
- the aggregated number of unique task workers (may be restricted to a certain interval)
-
deleteTaskMetrics
Deletes all task metrics which are older than the specified timestamp. If the timestamp is null, all metrics will be deleted- Parameters:
timestamp- ornull- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
createBatchQuery
BatchQuery createBatchQuery()Creates a query to search forBatchinstances.- Since:
- 7.5
-
suspendBatchById
Suspends the
Batchwith the given id immediately.Note: All
JobDefinitions andJobs related to the provided batch will be suspended.- Throws:
BadUserRequestException- If no such batch can be found.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.BATCH.- Since:
- 7.5
-
activateBatchById
Activates the
Batchwith the given id immediately.Note: All
JobDefinitions andJobs related to the provided batch will be activated.- Throws:
BadUserRequestException- If no such batch can be found.AuthorizationException- If the user has noPermissions.UPDATEpermission onResources.BATCH.- Since:
- 7.5
-
deleteBatch
Deletes a batch instance and the corresponding job definitions. If cascade is set to true the historic batch instances and the historic jobs logs are also removed.- Throws:
AuthorizationException- If the user has noPermissions.DELETEpermission onResources.BATCH- Since:
- 7.5
-
createBatchStatisticsQuery
BatchStatisticsQuery createBatchStatisticsQuery()Query for the statistics of the batch execution jobs of a batch.- Since:
- 7.5
-
createSchemaLogQuery
SchemaLogQuery createSchemaLogQuery()Query for entries of the database schema log.- Since:
- 7.11
-
toggleTelemetry
void toggleTelemetry(boolean enabled) Enable/disable sending telemetry data to Camunda- Throws:
AuthorizationException- If the user is not a member of the groupGroups.CAMUNDA_ADMIN.
-
isTelemetryEnabled
Boolean isTelemetryEnabled()Checks how sending telemetry data to Camunda is configured- Returns:
nullif the configuration is not defined so far, treated asfalseand no data is sent,trueif the telemetry sending is enabled, andfalseif the telemetry is disabled explicitly.
-
getTelemetryData
TelemetryData getTelemetryData()This method returns the current state of the collected telemetry data. For a detailed explanation on what is included, read the Telemetry page in the Camunda docs. The engine collects information about multiple aspects of the installation. If telemetry is enabled this information is sent to Camunda. If telemetry is disabled, the engine still collects this information.- See Also:
-