Package org.flowable.eventregistry.impl.persistence.deploy

Class EventDeploymentManager

java.lang.Object

org.flowable.eventregistry.impl.persistence.deploy.EventDeploymentManager

public class EventDeploymentManager
extends Object

Author:

Tijs Rademakers, Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected DeploymentCache<ChannelDefinitionCacheEntry>	channelDefinitionCache
protected ChannelDefinitionEntityManager	channelDefinitionEntityManager
protected List<Deployer>	deployers
protected EventDeploymentEntityManager	deploymentEntityManager
protected EventRegistryEngineConfiguration	engineConfig
protected DeploymentCache<EventDefinitionCacheEntry>	eventDefinitionCache
protected EventDefinitionEntityManager	eventDefinitionEntityManager

Constructor Summary

Constructors

Constructor	Description
EventDeploymentManager(DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache, DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache, EventRegistryEngineConfiguration engineConfig)

Method Summary

Modifier and Type	Method	Description
void	deploy(EventDeploymentEntity deployment)
ChannelDefinitionEntity	findDeployedChannelDefinitionById(String channelDefinitionId)
EventDefinitionEntity	findDeployedEventDefinitionById(String eventDefinitionId)
EventDefinitionEntity	findDeployedEventDefinitionByKeyAndVersionAndTenantId(String eventDefinitionKey, int eventVersion, String tenantId)
ChannelDefinitionEntity	findDeployedLatestChannelDefinitionByKey(String channelDefinitionKey)
EventDefinitionEntity	findDeployedLatestEventDefinitionByKey(String eventDefinitionKey)
EventDefinitionEntity	findDeployedLatestEventDefinitionByKeyAndDeploymentId(String eventDefinitionKey, String deploymentId)
EventDefinitionEntity	findDeployedLatestEventDefinitionByKeyAndTenantId(String eventDefinitionKey, String tenantId)
EventDefinitionEntity	findDeployedLatestEventDefinitionByKeyDeploymentIdAndTenantId(String eventDefinitionKey, String deploymentId, String tenantId)
DeploymentCache<ChannelDefinitionCacheEntry>	getChannelDefinitionCache()
ChannelDefinitionEntityManager	getChannelDefinitionEntityManager()
List<Deployer>	getDeployers()
EventDeploymentEntityManager	getDeploymentEntityManager()
DeploymentCache<EventDefinitionCacheEntry>	getEventDefinitionCache()
EventDefinitionEntityManager	getEventDefinitionEntityManager()
ChannelDefinition	removeChannelDefinitionFromCache(String channelDefinitionId)
void	removeChannelDefinitionFromCache(ChannelDefinition channelDefinition)
void	removeDeployment(String deploymentId)
ChannelDefinitionCacheEntry	resolveChannelDefinition(ChannelDefinition channelDefinition)	Resolving the channel will fetch the channel definition, parse it and store the ChannelDefinition in memory.
EventDefinitionCacheEntry	resolveEventDefinition(EventDefinition eventDefinition)	Resolving the event will fetch the event definition, parse it and store the EventDefinition in memory.
void	setChannelDefinitionCache(DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache)
void	setChannelDefinitionEntityManager(ChannelDefinitionEntityManager channelDefinitionEntityManager)
void	setDeployers(List<Deployer> deployers)
void	setDeploymentEntityManager(EventDeploymentEntityManager deploymentEntityManager)
void	setEventDefinitionCache(DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache)
void	setEventDefinitionEntityManager(EventDefinitionEntityManager eventDefinitionEntityManager)

Methods inherited from class java.lang.Object

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

Field Details

engineConfig

protected EventRegistryEngineConfiguration engineConfig

eventDefinitionCache

protected DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache

channelDefinitionCache

protected DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache

deployers

protected List<Deployer> deployers

eventDefinitionEntityManager

protected EventDefinitionEntityManager eventDefinitionEntityManager

channelDefinitionEntityManager

protected ChannelDefinitionEntityManager channelDefinitionEntityManager

deploymentEntityManager

protected EventDeploymentEntityManager deploymentEntityManager

Constructor Details

EventDeploymentManager

public EventDeploymentManager(DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache,
 DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache,
 EventRegistryEngineConfiguration engineConfig)

Method Details

deploy

public void deploy(EventDeploymentEntity deployment)

findDeployedEventDefinitionById

public EventDefinitionEntity findDeployedEventDefinitionById(String eventDefinitionId)

findDeployedChannelDefinitionById

public ChannelDefinitionEntity findDeployedChannelDefinitionById(String channelDefinitionId)

findDeployedLatestEventDefinitionByKey

public EventDefinitionEntity findDeployedLatestEventDefinitionByKey(String eventDefinitionKey)

findDeployedLatestChannelDefinitionByKey

public ChannelDefinitionEntity findDeployedLatestChannelDefinitionByKey(String channelDefinitionKey)

findDeployedLatestEventDefinitionByKeyAndTenantId

public EventDefinitionEntity findDeployedLatestEventDefinitionByKeyAndTenantId(String eventDefinitionKey,
 String tenantId)

findDeployedLatestEventDefinitionByKeyAndDeploymentId

public EventDefinitionEntity findDeployedLatestEventDefinitionByKeyAndDeploymentId(String eventDefinitionKey,
 String deploymentId)

findDeployedLatestEventDefinitionByKeyDeploymentIdAndTenantId

public EventDefinitionEntity findDeployedLatestEventDefinitionByKeyDeploymentIdAndTenantId(String eventDefinitionKey,
 String deploymentId,
 String tenantId)

findDeployedEventDefinitionByKeyAndVersionAndTenantId

public EventDefinitionEntity findDeployedEventDefinitionByKeyAndVersionAndTenantId(String eventDefinitionKey,
 int eventVersion,
 String tenantId)

resolveEventDefinition

public EventDefinitionCacheEntry resolveEventDefinition(EventDefinition eventDefinition)

Resolving the event will fetch the event definition, parse it and store the EventDefinition in memory.

resolveChannelDefinition

public ChannelDefinitionCacheEntry resolveChannelDefinition(ChannelDefinition channelDefinition)

Resolving the channel will fetch the channel definition, parse it and store the ChannelDefinition in memory.

removeDeployment

public void removeDeployment(String deploymentId)

removeChannelDefinitionFromCache

public void removeChannelDefinitionFromCache(ChannelDefinition channelDefinition)

removeChannelDefinitionFromCache

public ChannelDefinition removeChannelDefinitionFromCache(String channelDefinitionId)

getDeployers

public List<Deployer> getDeployers()

setDeployers

public void setDeployers(List<Deployer> deployers)

getEventDefinitionCache

public DeploymentCache<EventDefinitionCacheEntry> getEventDefinitionCache()

setEventDefinitionCache

public void setEventDefinitionCache(DeploymentCache<EventDefinitionCacheEntry> eventDefinitionCache)

getChannelDefinitionCache

public DeploymentCache<ChannelDefinitionCacheEntry> getChannelDefinitionCache()

setChannelDefinitionCache

public void setChannelDefinitionCache(DeploymentCache<ChannelDefinitionCacheEntry> channelDefinitionCache)

getEventDefinitionEntityManager

public EventDefinitionEntityManager getEventDefinitionEntityManager()

setEventDefinitionEntityManager

public void setEventDefinitionEntityManager(EventDefinitionEntityManager eventDefinitionEntityManager)

getChannelDefinitionEntityManager

public ChannelDefinitionEntityManager getChannelDefinitionEntityManager()

setChannelDefinitionEntityManager

public void setChannelDefinitionEntityManager(ChannelDefinitionEntityManager channelDefinitionEntityManager)

getDeploymentEntityManager

public EventDeploymentEntityManager getDeploymentEntityManager()

setDeploymentEntityManager

public void setDeploymentEntityManager(EventDeploymentEntityManager deploymentEntityManager)