org.camunda.bpm.engine.impl.persistence.deploy

Class DeploymentCache

java.lang.Object

org.camunda.bpm.engine.impl.persistence.deploy.DeploymentCache

public class DeploymentCache
extends Object

Author:

Tom Baeyens, Falko Menge

Field Summary

Fields

Modifier and Type	Field and Description
protected org.camunda.commons.utils.cache.Cache<String,BpmnModelInstance>	bpmnModelInstanceCache
protected org.camunda.commons.utils.cache.Cache<String,CaseDefinitionEntity>	caseDefinitionCache
protected org.camunda.commons.utils.cache.Cache<String,CmmnModelInstance>	cmmnModelInstanceCache
protected org.camunda.commons.utils.cache.Cache<String,DecisionDefinitionEntity>	decisionDefinitionCache
protected org.camunda.commons.utils.cache.Cache<String,DecisionRequirementsDefinitionEntity>	decisionRequirementsDefinitionCache
protected List<Deployer>	deployers
protected org.camunda.commons.utils.cache.Cache<String,DmnModelInstance>	dmnModelInstanceCache
protected static EnginePersistenceLogger	LOG
protected org.camunda.commons.utils.cache.Cache<String,ProcessDefinitionEntity>	processDefinitionEntityCache

Constructor Summary

Constructors

Constructor and Description
DeploymentCache(CacheFactory factory, int cacheCapacity)

Method Summary

Methods

Modifier and Type	Method and Description
void	addCaseDefinition(CaseDefinitionEntity caseDefinition)
void	addDecisionDefinition(DecisionDefinitionEntity decisionDefinition)
void	addDecisionRequirementsDefinition(DecisionRequirementsDefinitionEntity decisionRequirementsDefinition)
void	addProcessDefinition(ProcessDefinitionEntity processDefinition)
void	deploy(DeploymentEntity deployment)
void	discardCaseDefinitionCache()
void	discardDecisionDefinitionCache()
void	discardDecisionRequirementsDefinitionCache()
void	discardProcessDefinitionCache()
BpmnModelInstance	findBpmnModelInstanceForProcessDefinition(ProcessDefinitionEntity processDefinitionEntity)
BpmnModelInstance	findBpmnModelInstanceForProcessDefinition(String processDefinitionId)
CaseDefinitionEntity	findCaseDefinitionFromCache(String caseDefinitionId)
CmmnModelInstance	findCmmnModelInstanceForCaseDefinition(String caseDefinitionId)
DecisionDefinitionEntity	findDecisionDefinitionFromCache(String decisionDefinitionId)
DecisionRequirementsDefinitionEntity	findDecisionRequirementsDefinitionFromCache(String decisionRequirementsDefinitionId)
CaseDefinitionEntity	findDeployedCaseDefinitionByDeploymentAndKey(String deploymentId, String caseDefinitionKey)
CaseDefinitionEntity	findDeployedCaseDefinitionById(String caseDefinitionId)
CaseDefinitionEntity	findDeployedCaseDefinitionByKeyVersionAndTenantId(String caseDefinitionKey, Integer caseDefinitionVersion, String tenantId)
DecisionDefinition	findDeployedDecisionDefinitionByDeploymentAndKey(String deploymentId, String decisionDefinitionKey)
DecisionDefinitionEntity	findDeployedDecisionDefinitionById(String decisionDefinitionId)
DecisionDefinition	findDeployedDecisionDefinitionByKeyAndVersion(String decisionDefinitionKey, Integer decisionDefinitionVersion)
DecisionDefinition	findDeployedDecisionDefinitionByKeyVersionAndTenantId(String decisionDefinitionKey, Integer decisionDefinitionVersion, String tenantId)
DecisionRequirementsDefinitionEntity	findDeployedDecisionRequirementsDefinitionById(String decisionRequirementsDefinitionId)
CaseDefinitionEntity	findDeployedLatestCaseDefinitionByKey(String caseDefinitionKey)
CaseDefinitionEntity	findDeployedLatestCaseDefinitionByKeyAndTenantId(String caseDefinitionKey, String tenantId)
DecisionDefinition	findDeployedLatestDecisionDefinitionByKey(String decisionDefinitionKey)
DecisionDefinition	findDeployedLatestDecisionDefinitionByKeyAndTenantId(String decisionDefinitionKey, String tenantId)
ProcessDefinitionEntity	findDeployedLatestProcessDefinitionByKey(String processDefinitionKey)
ProcessDefinitionEntity	findDeployedLatestProcessDefinitionByKeyAndTenantId(String processDefinitionKey, String tenantId)
ProcessDefinitionEntity	findDeployedProcessDefinitionByDeploymentAndKey(String deploymentId, String processDefinitionKey)
ProcessDefinitionEntity	findDeployedProcessDefinitionById(String processDefinitionId)
ProcessDefinitionEntity	findDeployedProcessDefinitionByKeyVersionAndTenantId(String processDefinitionKey, Integer processDefinitionVersion, String tenantId)
DmnModelInstance	findDmnModelInstanceForDecisionDefinition(String decisionDefinitionId)
ProcessDefinitionEntity	findProcessDefinitionFromCache(String processDefinitionId)
org.camunda.commons.utils.cache.Cache<String,BpmnModelInstance>	getBpmnModelInstanceCache()
CaseDefinitionEntity	getCaseDefinitionById(String caseDefinitionId)
org.camunda.commons.utils.cache.Cache<String,CaseDefinitionEntity>	getCaseDefinitionCache()
org.camunda.commons.utils.cache.Cache<String,CmmnModelInstance>	getCmmnModelInstanceCache()
org.camunda.commons.utils.cache.Cache<String,DecisionDefinitionEntity>	getDecisionDefinitionCache()
org.camunda.commons.utils.cache.Cache<String,DecisionRequirementsDefinitionEntity>	getDecisionRequirementsDefinitionCache()
List<Deployer>	getDeployers()
org.camunda.commons.utils.cache.Cache<String,DmnModelInstance>	getDmnModelInstanceCache()
org.camunda.commons.utils.cache.Cache<String,ProcessDefinitionEntity>	getProcessDefinitionCache()
protected void	initDeployment(DeploymentEntity deployment, String... resourceNames)
protected BpmnModelInstance	loadAndCacheBpmnModelInstance(ProcessDefinitionEntity processDefinitionEntity)
CachePurgeReport	purgeCache()
protected void	removeAllCaseDefinitionsByDeploymentId(String deploymentId)
protected void	removeAllDecisionDefinitionsByDeploymentId(String deploymentId)
protected void	removeAllDecisionRequirementsDefinitionsByDeploymentId(String deploymentId)
protected void	removeAllProcessDefinitionsByDeploymentId(String deploymentId)
void	removeCaseDefinition(String caseDefinitionId)
void	removeDecisionDefinition(String decisionDefinitionId)
void	removeDecisionRequirementsDefinition(String decisionRequirementsDefinitionId)
void	removeDeployment(String deploymentId)
void	removeProcessDefinition(String processDefinitionId)
CaseDefinitionEntity	resolveCaseDefinition(CaseDefinitionEntity caseDefinition)
DecisionDefinitionEntity	resolveDecisionDefinition(DecisionDefinitionEntity decisionDefinition)
DecisionRequirementsDefinitionEntity	resolveDecisionRequirementsDefinition(DecisionRequirementsDefinitionEntity decisionRequirementsDefinition)
ProcessDefinitionEntity	resolveProcessDefinition(ProcessDefinitionEntity processDefinition)
void	setCaseDefinitionCache(org.camunda.commons.utils.cache.Cache<String,CaseDefinitionEntity> caseDefinitionCache)
void	setDeployers(List<Deployer> deployers)
void	setProcessDefinitionCache(org.camunda.commons.utils.cache.Cache<String,ProcessDefinitionEntity> processDefinitionEntityCache)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final EnginePersistenceLogger LOG

processDefinitionEntityCache

protected org.camunda.commons.utils.cache.Cache<String,ProcessDefinitionEntity> processDefinitionEntityCache

caseDefinitionCache

protected org.camunda.commons.utils.cache.Cache<String,CaseDefinitionEntity> caseDefinitionCache

decisionDefinitionCache

protected org.camunda.commons.utils.cache.Cache<String,DecisionDefinitionEntity> decisionDefinitionCache

decisionRequirementsDefinitionCache

protected org.camunda.commons.utils.cache.Cache<String,DecisionRequirementsDefinitionEntity> decisionRequirementsDefinitionCache

bpmnModelInstanceCache

protected org.camunda.commons.utils.cache.Cache<String,BpmnModelInstance> bpmnModelInstanceCache

cmmnModelInstanceCache

protected org.camunda.commons.utils.cache.Cache<String,CmmnModelInstance> cmmnModelInstanceCache

dmnModelInstanceCache

protected org.camunda.commons.utils.cache.Cache<String,DmnModelInstance> dmnModelInstanceCache

deployers

protected List<Deployer> deployers

Constructor Detail

DeploymentCache

public DeploymentCache(CacheFactory factory,
               int cacheCapacity)

Method Detail

deploy

public void deploy(DeploymentEntity deployment)

initDeployment

protected void initDeployment(DeploymentEntity deployment,
                  String... resourceNames)

findProcessDefinitionFromCache

public ProcessDefinitionEntity findProcessDefinitionFromCache(String processDefinitionId)

findDeployedProcessDefinitionById

public ProcessDefinitionEntity findDeployedProcessDefinitionById(String processDefinitionId)

findDeployedLatestProcessDefinitionByKey

public ProcessDefinitionEntity findDeployedLatestProcessDefinitionByKey(String processDefinitionKey)

Returns:

the latest version of the process definition with the given key (from any tenant)

Throws:

ProcessEngineException - if more than one tenant has a process definition with the given key

See Also:

findDeployedLatestProcessDefinitionByKeyAndTenantId(String, String)

findDeployedLatestProcessDefinitionByKeyAndTenantId

public ProcessDefinitionEntity findDeployedLatestProcessDefinitionByKeyAndTenantId(String processDefinitionKey,
                                                                          String tenantId)

Returns:

the latest version of the process definition with the given key and tenant id

findDeployedProcessDefinitionByKeyVersionAndTenantId

public ProcessDefinitionEntity findDeployedProcessDefinitionByKeyVersionAndTenantId(String processDefinitionKey,
                                                                           Integer processDefinitionVersion,
                                                                           String tenantId)

findDeployedProcessDefinitionByDeploymentAndKey

public ProcessDefinitionEntity findDeployedProcessDefinitionByDeploymentAndKey(String deploymentId,
                                                                      String processDefinitionKey)

resolveProcessDefinition

public ProcessDefinitionEntity resolveProcessDefinition(ProcessDefinitionEntity processDefinition)

findBpmnModelInstanceForProcessDefinition

public BpmnModelInstance findBpmnModelInstanceForProcessDefinition(ProcessDefinitionEntity processDefinitionEntity)

findBpmnModelInstanceForProcessDefinition

public BpmnModelInstance findBpmnModelInstanceForProcessDefinition(String processDefinitionId)

loadAndCacheBpmnModelInstance

protected BpmnModelInstance loadAndCacheBpmnModelInstance(ProcessDefinitionEntity processDefinitionEntity)

addProcessDefinition

public void addProcessDefinition(ProcessDefinitionEntity processDefinition)

removeProcessDefinition

public void removeProcessDefinition(String processDefinitionId)

discardProcessDefinitionCache

public void discardProcessDefinitionCache()

findCaseDefinitionFromCache

public CaseDefinitionEntity findCaseDefinitionFromCache(String caseDefinitionId)

findDeployedCaseDefinitionById

public CaseDefinitionEntity findDeployedCaseDefinitionById(String caseDefinitionId)

findDeployedLatestCaseDefinitionByKey

public CaseDefinitionEntity findDeployedLatestCaseDefinitionByKey(String caseDefinitionKey)

Returns:

the latest version of the case definition with the given key (from any tenant)

Throws:

ProcessEngineException - if more than one tenant has a case definition with the given key

See Also:

findDeployedLatestCaseDefinitionByKeyAndTenantId(String, String)

findDeployedLatestCaseDefinitionByKeyAndTenantId

public CaseDefinitionEntity findDeployedLatestCaseDefinitionByKeyAndTenantId(String caseDefinitionKey,
                                                                    String tenantId)

Returns:

the latest version of the case definition with the given key and tenant id

findDeployedCaseDefinitionByKeyVersionAndTenantId

public CaseDefinitionEntity findDeployedCaseDefinitionByKeyVersionAndTenantId(String caseDefinitionKey,
                                                                     Integer caseDefinitionVersion,
                                                                     String tenantId)

findDeployedCaseDefinitionByDeploymentAndKey

public CaseDefinitionEntity findDeployedCaseDefinitionByDeploymentAndKey(String deploymentId,
                                                                String caseDefinitionKey)

getCaseDefinitionById

public CaseDefinitionEntity getCaseDefinitionById(String caseDefinitionId)

resolveCaseDefinition

public CaseDefinitionEntity resolveCaseDefinition(CaseDefinitionEntity caseDefinition)

findCmmnModelInstanceForCaseDefinition

public CmmnModelInstance findCmmnModelInstanceForCaseDefinition(String caseDefinitionId)

addCaseDefinition

public void addCaseDefinition(CaseDefinitionEntity caseDefinition)

removeCaseDefinition

public void removeCaseDefinition(String caseDefinitionId)

discardCaseDefinitionCache

public void discardCaseDefinitionCache()

findDecisionDefinitionFromCache

public DecisionDefinitionEntity findDecisionDefinitionFromCache(String decisionDefinitionId)

findDeployedDecisionDefinitionById

public DecisionDefinitionEntity findDeployedDecisionDefinitionById(String decisionDefinitionId)

findDeployedLatestDecisionDefinitionByKey

public DecisionDefinition findDeployedLatestDecisionDefinitionByKey(String decisionDefinitionKey)

findDeployedLatestDecisionDefinitionByKeyAndTenantId

public DecisionDefinition findDeployedLatestDecisionDefinitionByKeyAndTenantId(String decisionDefinitionKey,
                                                                      String tenantId)

findDeployedDecisionDefinitionByDeploymentAndKey

public DecisionDefinition findDeployedDecisionDefinitionByDeploymentAndKey(String deploymentId,
                                                                  String decisionDefinitionKey)

findDeployedDecisionDefinitionByKeyAndVersion

public DecisionDefinition findDeployedDecisionDefinitionByKeyAndVersion(String decisionDefinitionKey,
                                                               Integer decisionDefinitionVersion)

findDeployedDecisionDefinitionByKeyVersionAndTenantId

public DecisionDefinition findDeployedDecisionDefinitionByKeyVersionAndTenantId(String decisionDefinitionKey,
                                                                       Integer decisionDefinitionVersion,
                                                                       String tenantId)

resolveDecisionDefinition

public DecisionDefinitionEntity resolveDecisionDefinition(DecisionDefinitionEntity decisionDefinition)

findDmnModelInstanceForDecisionDefinition

public DmnModelInstance findDmnModelInstanceForDecisionDefinition(String decisionDefinitionId)

addDecisionDefinition

public void addDecisionDefinition(DecisionDefinitionEntity decisionDefinition)

removeDecisionDefinition

public void removeDecisionDefinition(String decisionDefinitionId)

discardDecisionDefinitionCache

public void discardDecisionDefinitionCache()

addDecisionRequirementsDefinition

public void addDecisionRequirementsDefinition(DecisionRequirementsDefinitionEntity decisionRequirementsDefinition)

findDecisionRequirementsDefinitionFromCache

public DecisionRequirementsDefinitionEntity findDecisionRequirementsDefinitionFromCache(String decisionRequirementsDefinitionId)

findDeployedDecisionRequirementsDefinitionById

public DecisionRequirementsDefinitionEntity findDeployedDecisionRequirementsDefinitionById(String decisionRequirementsDefinitionId)

resolveDecisionRequirementsDefinition

public DecisionRequirementsDefinitionEntity resolveDecisionRequirementsDefinition(DecisionRequirementsDefinitionEntity decisionRequirementsDefinition)

discardDecisionRequirementsDefinitionCache

public void discardDecisionRequirementsDefinitionCache()

removeDecisionRequirementsDefinition

public void removeDecisionRequirementsDefinition(String decisionRequirementsDefinitionId)

getBpmnModelInstanceCache

public org.camunda.commons.utils.cache.Cache<String,BpmnModelInstance> getBpmnModelInstanceCache()

getCmmnModelInstanceCache

public org.camunda.commons.utils.cache.Cache<String,CmmnModelInstance> getCmmnModelInstanceCache()

getDmnModelInstanceCache

public org.camunda.commons.utils.cache.Cache<String,DmnModelInstance> getDmnModelInstanceCache()

getDecisionDefinitionCache

public org.camunda.commons.utils.cache.Cache<String,DecisionDefinitionEntity> getDecisionDefinitionCache()

getDecisionRequirementsDefinitionCache

public org.camunda.commons.utils.cache.Cache<String,DecisionRequirementsDefinitionEntity> getDecisionRequirementsDefinitionCache()

getProcessDefinitionCache

public org.camunda.commons.utils.cache.Cache<String,ProcessDefinitionEntity> getProcessDefinitionCache()

setProcessDefinitionCache

public void setProcessDefinitionCache(org.camunda.commons.utils.cache.Cache<String,ProcessDefinitionEntity> processDefinitionEntityCache)

getCaseDefinitionCache

public org.camunda.commons.utils.cache.Cache<String,CaseDefinitionEntity> getCaseDefinitionCache()

setCaseDefinitionCache

public void setCaseDefinitionCache(org.camunda.commons.utils.cache.Cache<String,CaseDefinitionEntity> caseDefinitionCache)

getDeployers

public List<Deployer> getDeployers()

setDeployers

public void setDeployers(List<Deployer> deployers)

removeDeployment

public void removeDeployment(String deploymentId)

removeAllProcessDefinitionsByDeploymentId

protected void removeAllProcessDefinitionsByDeploymentId(String deploymentId)

removeAllCaseDefinitionsByDeploymentId

protected void removeAllCaseDefinitionsByDeploymentId(String deploymentId)

removeAllDecisionDefinitionsByDeploymentId

protected void removeAllDecisionDefinitionsByDeploymentId(String deploymentId)

removeAllDecisionRequirementsDefinitionsByDeploymentId

protected void removeAllDecisionRequirementsDefinitionsByDeploymentId(String deploymentId)

purgeCache

public CachePurgeReport purgeCache()