Package org.ikasan.configurationService.service

Class ConfiguredResourceConfigurationService

  • All Implemented Interfaces:
    org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>, org.ikasan.spec.configuration.ConfigurationService<org.ikasan.spec.configuration.ConfiguredResource>
    public class ConfiguredResourceConfigurationService
extends java.lang.Object
implements org.ikasan.spec.configuration.ConfigurationService<org.ikasan.spec.configuration.ConfiguredResource>, org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>
    Implementation of the Configuration Service based on a ConfiguredResource.
    Author:
    Ikasan Development Team

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void configure​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
      Retrieves the persisted configuration based on the configuredResource's configurationId and applies the persisted configuration to the configuration of the configuredResource.
      org.ikasan.spec.configuration.Configuration createConfiguration​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
      Create a new dao instance for the given ConfiguredResource.
      void deleteConfiguration​(org.ikasan.spec.configuration.Configuration configuration)  
      org.ikasan.spec.configuration.Configuration getConfiguration​(java.lang.String configuredResourceId)  
      org.ikasan.spec.configuration.Configuration getConfiguration​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)  
      static org.ikasan.spec.configuration.ConfigurationService getDefaultConfigurationService()
      Default configuration service returns a cached based instance.
      void saveConfiguration​(org.ikasan.spec.configuration.Configuration configuration)  
      void setConfigurationFactory​(org.ikasan.spec.configuration.ConfigurationFactory configurationFactory)
      Allow the configurationFactory to be overridden
      void update​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
      Updates the persisted dao with the current configuredResource's dao.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ConfiguredResourceConfigurationService

        public ConfiguredResourceConfigurationService​(ConfigurationDao staticConfigurationDao,
                                              ConfigurationDao dynamicConfigurationDao)
        Constructor
        Parameters:
        staticConfigurationDao - - used to update configuration outside a runtime transaction
        dynamicConfigurationDao - - used to update configuration at runtime within a transaction

    • Method Detail

      • getDefaultConfigurationService

        public static org.ikasan.spec.configuration.ConfigurationService getDefaultConfigurationService()
        Default configuration service returns a cached based instance.
        Returns:

      • setConfigurationFactory

        public void setConfigurationFactory​(org.ikasan.spec.configuration.ConfigurationFactory configurationFactory)
        Allow the configurationFactory to be overridden
        Specified by:
        setConfigurationFactory in interface org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>
        Parameters:
        configurationFactory -

      • configure

        public void configure​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
        Retrieves the persisted configuration based on the configuredResource's configurationId and applies the persisted configuration to the configuration of the configuredResource. This is typically called just prior to the flow being started.
        Specified by:
        configure in interface org.ikasan.spec.configuration.ConfigurationService<org.ikasan.spec.configuration.ConfiguredResource>
        Parameters:
        configuredResource -

      • createConfiguration

        public org.ikasan.spec.configuration.Configuration createConfiguration​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
        Create a new dao instance for the given ConfiguredResource.
        Specified by:
        createConfiguration in interface org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>
        Parameters:
        configuredResource -
        Returns:
        Configuration

      • update

        public void update​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
        Updates the persisted dao with the current configuredResource's dao. This is typically used for dynamically updated dao ie. sequence numbers which change onEvent.
        Specified by:
        update in interface org.ikasan.spec.configuration.ConfigurationService<org.ikasan.spec.configuration.ConfiguredResource>
        Parameters:
        configuredResource -

      • deleteConfiguration

        public void deleteConfiguration​(org.ikasan.spec.configuration.Configuration configuration)
        Specified by:
        deleteConfiguration in interface org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>

      • saveConfiguration

        public void saveConfiguration​(org.ikasan.spec.configuration.Configuration configuration)
        Specified by:
        saveConfiguration in interface org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>

      • getConfiguration

        public org.ikasan.spec.configuration.Configuration getConfiguration​(org.ikasan.spec.configuration.ConfiguredResource configuredResource)
        Specified by:
        getConfiguration in interface org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>

      • getConfiguration

        public org.ikasan.spec.configuration.Configuration getConfiguration​(java.lang.String configuredResourceId)
        Specified by:
        getConfiguration in interface org.ikasan.spec.configuration.ConfigurationManagement<org.ikasan.spec.configuration.ConfiguredResource,​org.ikasan.spec.configuration.Configuration>