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 Map<String,BpmnModelInstance>	bpmnModelInstanceCache
protected Map<String,CaseDefinitionEntity>	caseDefinitionCache
protected Map<String,CmmnModelInstance>	cmmnModelInstanceCache
protected Map<String,DecisionDefinitionEntity>	decisionDefinitionCache
protected List<Deployer>	deployers
protected Map<String,DmnModelInstance>	dmnModelInstanceCache
protected static EnginePersistenceLogger	LOG
protected Map<String,ProcessDefinitionEntity>	processDefinitionCache

Constructor Summary

Constructors

Constructor and Description
DeploymentCache()

Method Summary

Methods

Modifier and Type	Method and Description
void	addCaseDefinition(CaseDefinitionEntity caseDefinition)
void	addDecisionDefinition(DecisionDefinitionEntity decisionDefinition)
void	addProcessDefinition(ProcessDefinitionEntity processDefinition)
void	deploy(DeploymentEntity deployment)
void	discardCaseDefinitionCache()
void	discardDecisionDefinitionCache()
void	discardProcessDefinitionCache()
BpmnModelInstance	findBpmnModelInstanceForProcessDefinition(ProcessDefinitionEntity processDefinitionEntity)
BpmnModelInstance	findBpmnModelInstanceForProcessDefinition(String processDefinitionId)
CaseDefinitionEntity	findCaseDefinitionFromCache(String caseDefinitionId)
CmmnModelInstance	findCmmnModelInstanceForCaseDefinition(String caseDefinitionId)
DecisionDefinitionEntity	findDecisionDefinitionFromCache(String decisionDefinitionId)
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)
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)
Map<String,BpmnModelInstance>	getBpmnModelInstanceCache()
CaseDefinitionEntity	getCaseDefinitionById(String caseDefinitionId)
Map<String,CaseDefinitionEntity>	getCaseDefinitionCache()
Map<String,CmmnModelInstance>	getCmmnModelInstanceCache()
Map<String,DecisionDefinitionEntity>	getDecisionDefinitionCache()
List<Deployer>	getDeployers()
Map<String,DmnModelInstance>	getDmnModelInstanceCache()
Map<String,ProcessDefinitionEntity>	getProcessDefinitionCache()
protected BpmnModelInstance	loadAndCacheBpmnModelInstance(ProcessDefinitionEntity processDefinitionEntity)
CachePurgeReport	purgeCache()
protected void	removeAllCaseDefinitionsByDeploymentId(String deploymentId)
protected void	removeAllDecisionDefinitionsByDeploymentId(String deploymentId)
protected void	removeAllProcessDefinitionsByDeploymentId(String deploymentId)
void	removeCaseDefinition(String caseDefinitionId)
void	removeDecisionDefinition(String decisionDefinitionId)
void	removeDeployment(String deploymentId)
void	removeProcessDefinition(String processDefinitionId)
CaseDefinitionEntity	resolveCaseDefinition(CaseDefinitionEntity caseDefinition)
DecisionDefinitionEntity	resolveDecisionDefinition(DecisionDefinitionEntity decisionDefinition)
ProcessDefinitionEntity	resolveProcessDefinition(ProcessDefinitionEntity processDefinition)
void	setCaseDefinitionCache(Map<String,CaseDefinitionEntity> caseDefinitionCache)
void	setDeployers(List<Deployer> deployers)
void	setProcessDefinitionCache(Map<String,ProcessDefinitionEntity> processDefinitionCache)

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

processDefinitionCache

protected Map<String,ProcessDefinitionEntity> processDefinitionCache

caseDefinitionCache

protected Map<String,CaseDefinitionEntity> caseDefinitionCache

decisionDefinitionCache

protected Map<String,DecisionDefinitionEntity> decisionDefinitionCache

bpmnModelInstanceCache

protected Map<String,BpmnModelInstance> bpmnModelInstanceCache

cmmnModelInstanceCache

protected Map<String,CmmnModelInstance> cmmnModelInstanceCache

dmnModelInstanceCache

protected Map<String,DmnModelInstance> dmnModelInstanceCache

deployers

protected List<Deployer> deployers

Constructor Detail

DeploymentCache

public DeploymentCache()

Method Detail

deploy

public void deploy(DeploymentEntity deployment)

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()

getBpmnModelInstanceCache

public Map<String,BpmnModelInstance> getBpmnModelInstanceCache()

getCmmnModelInstanceCache

public Map<String,CmmnModelInstance> getCmmnModelInstanceCache()

getDmnModelInstanceCache

public Map<String,DmnModelInstance> getDmnModelInstanceCache()

getProcessDefinitionCache

public Map<String,ProcessDefinitionEntity> getProcessDefinitionCache()

getDecisionDefinitionCache

public Map<String,DecisionDefinitionEntity> getDecisionDefinitionCache()

setProcessDefinitionCache

public void setProcessDefinitionCache(Map<String,ProcessDefinitionEntity> processDefinitionCache)

getCaseDefinitionCache

public Map<String,CaseDefinitionEntity> getCaseDefinitionCache()

setCaseDefinitionCache

public void setCaseDefinitionCache(Map<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)

purgeCache

public CachePurgeReport purgeCache()