Package org.camunda.bpm.engine.impl.jobexecutor

Class DefaultJobPriorityProvider

java.lang.Object

org.camunda.bpm.engine.impl.DefaultPriorityProvider<JobDeclaration<?,?>>

org.camunda.bpm.engine.impl.jobexecutor.DefaultJobPriorityProvider

All Implemented Interfaces:

PriorityProvider<JobDeclaration<?,?>>

public class DefaultJobPriorityProvider
extends DefaultPriorityProvider<JobDeclaration<?,?>>

Author:

Thorben Lindhauer, Christopher Zell

Field Summary

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

DEFAULT_PRIORITY, DEFAULT_PRIORITY_ON_RESOLUTION_FAILURE

Constructor Summary

Constructors

Constructor	Description
DefaultJobPriorityProvider()

Method Summary

Modifier and Type	Method	Description
protected String	describeContext(JobDeclaration<?,?> jobDeclaration, ExecutionEntity executionEntity)
protected Long	getActivityPriority(ExecutionEntity execution, JobDeclaration<?,?> jobDeclaration)
protected JobDefinitionEntity	getJobDefinitionFor(String jobDefinitionId)
protected Long	getProcessDefinitionPriority(ExecutionEntity execution, JobDeclaration<?,?> jobDeclaration)	Returns the priority defined in the process definition.
protected Long	getSpecificPriority(ExecutionEntity execution, JobDeclaration<?,?> param, String jobDefinitionId)	Returns the priority defined in the specific entity.
protected void	logNotDeterminingPriority(ExecutionEntity execution, Object value, ProcessEngineException e)	Logs the exception which was thrown if the priority can not be determined.

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

determinePriority, evaluateValueProvider, getDefaultPriority, getDefaultPriorityOnResolutionFailure, getProcessDefinedPriority, isSymptomOfContextSwitchFailure, isValidLongValue

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultJobPriorityProvider

public DefaultJobPriorityProvider()

Method Details

getSpecificPriority

protected Long getSpecificPriority(ExecutionEntity execution,
 JobDeclaration<?,?> param,
 String jobDefinitionId)

Description copied from class: DefaultPriorityProvider

Returns the priority defined in the specific entity. Like a job definition priority or an activity priority. The result can also be null in that case the process priority will be used.

Specified by:

getSpecificPriority in class DefaultPriorityProvider<JobDeclaration<?,?>>

Parameters:

execution - the current execution

param - the generic param

jobDefinitionId - the job definition id if related to a job

Returns:

the specific priority

getProcessDefinitionPriority

protected Long getProcessDefinitionPriority(ExecutionEntity execution,
 JobDeclaration<?,?> jobDeclaration)

Description copied from class: DefaultPriorityProvider

Returns the priority defined in the process definition. Can also be null in that case the fallback is the default priority.

Specified by:

getProcessDefinitionPriority in class DefaultPriorityProvider<JobDeclaration<?,?>>

Parameters:

execution - the current execution

jobDeclaration - the generic param

Returns:

the priority defined in the process definition

getJobDefinitionFor

protected JobDefinitionEntity getJobDefinitionFor(String jobDefinitionId)

getActivityPriority

protected Long getActivityPriority(ExecutionEntity execution,
 JobDeclaration<?,?> jobDeclaration)

logNotDeterminingPriority

protected void logNotDeterminingPriority(ExecutionEntity execution,
 Object value,
 ProcessEngineException e)

Description copied from class: DefaultPriorityProvider

Logs the exception which was thrown if the priority can not be determined.

Specified by:

logNotDeterminingPriority in class DefaultPriorityProvider<JobDeclaration<?,?>>

Parameters:

execution - the current execution entity

value - the current value

e - the exception which was catched

describeContext

protected String describeContext(JobDeclaration<?,?> jobDeclaration,
 ExecutionEntity executionEntity)