Package org.flowable.eventregistry.impl.deployer

Class EventDefinitionDeployer

java.lang.Object
org.flowable.eventregistry.impl.deployer.EventDefinitionDeployer
All Implemented Interfaces:
Deployer
public class EventDefinitionDeployer extends Object implements Deployer
Author:
Joram Barrez, Tijs Rademakers

  • Field Details

  • Constructor Details

    • EventDefinitionDeployer

      public EventDefinitionDeployer()

  • Method Details

    • deploy

      public void deploy(EventDeploymentEntity deployment)
      Specified by:
      deploy in interface Deployer

    • getPreviousVersionsOfEventDefinitions

      protected Map<EventDefinitionEntity,EventDefinitionEntity> getPreviousVersionsOfEventDefinitions(ParsedDeployment parsedDeployment)
      Constructs a map from new event definitions to the previous version by key and tenant. If no previous version exists, no map entry is created.

    • getPreviousVersionsOfChannelDefinitions

      protected Map<ChannelDefinitionEntity,ChannelDefinitionEntity> getPreviousVersionsOfChannelDefinitions(ParsedDeployment parsedDeployment)
      Constructs a map from new channel definitions to the previous version by key and tenant. If no previous version exists, no map entry is created.

    • setEventDefinitionVersionsAndIds

      protected void setEventDefinitionVersionsAndIds(ParsedDeployment parsedDeployment, Map<EventDefinitionEntity,EventDefinitionEntity> mapOfNewEventDefinitionToPreviousVersion)
      If the map contains an existing version for an event definition, then the event definition is updated, otherwise a new event definition is created.

    • setChannelDefinitionVersionsAndIds

      protected void setChannelDefinitionVersionsAndIds(ParsedDeployment parsedDeployment, Map<ChannelDefinitionEntity,ChannelDefinitionEntity> mapOfNewChannelDefinitionToPreviousVersion)
      If the map contains an existing version for a channel definition, then the channel definition is updated, otherwise a new channel definition is created.

    • persistEventDefinitions

      protected void persistEventDefinitions(ParsedDeployment parsedDeployment)
      Saves each event definition. It is assumed that the deployment is new, the definitions have never been saved before, and that they have all their values properly set up.

    • persistChannelDefinitions

      protected void persistChannelDefinitions(ParsedDeployment parsedDeployment)
      Saves each channel definition. It is assumed that the deployment is new, the definitions have never been saved before, and that they have all their values properly set up.

    • makeEventDefinitionsConsistentWithPersistedVersions

      protected void makeEventDefinitionsConsistentWithPersistedVersions(ParsedDeployment parsedDeployment)
      Loads the persisted version of each event definition and set values on the in-memory version to be consistent.

    • makeChannelDefinitionsConsistentWithPersistedVersions

      protected void makeChannelDefinitionsConsistentWithPersistedVersions(ParsedDeployment parsedDeployment)
      Loads the persisted version of each channel definition and set values on the in-memory version to be consistent.

    • getIdGenerator

      public IdGenerator getIdGenerator()

    • setIdGenerator

      public void setIdGenerator(IdGenerator idGenerator)

    • getExParsedDeploymentBuilderFactory

      public ParsedDeploymentBuilderFactory getExParsedDeploymentBuilderFactory()

    • setParsedDeploymentBuilderFactory

      public void setParsedDeploymentBuilderFactory(ParsedDeploymentBuilderFactory parsedDeploymentBuilderFactory)

    • getEventDeploymentHelper

      public EventDefinitionDeploymentHelper getEventDeploymentHelper()

    • setEventDeploymentHelper

      public void setEventDeploymentHelper(EventDefinitionDeploymentHelper eventDeploymentHelper)

    • getChannelDeploymentHelper

      public ChannelDefinitionDeploymentHelper getChannelDeploymentHelper()

    • setChannelDeploymentHelper

      public void setChannelDeploymentHelper(ChannelDefinitionDeploymentHelper channelDeploymentHelper)

    • getCachingAndArtifcatsManager

      public CachingAndArtifactsManager getCachingAndArtifcatsManager()

    • setCachingAndArtifactsManager

      public void setCachingAndArtifactsManager(CachingAndArtifactsManager manager)

    • isUsePrefixId

      public boolean isUsePrefixId()

    • setUsePrefixId

      public void setUsePrefixId(boolean usePrefixId)