diff options
Diffstat (limited to 'common-app-api/src/main/java/org/openecomp/sdc/be/config/ConfigurationManager.java')
-rw-r--r-- | common-app-api/src/main/java/org/openecomp/sdc/be/config/ConfigurationManager.java | 167 |
1 files changed, 88 insertions, 79 deletions
diff --git a/common-app-api/src/main/java/org/openecomp/sdc/be/config/ConfigurationManager.java b/common-app-api/src/main/java/org/openecomp/sdc/be/config/ConfigurationManager.java index f68cd52a56..f5891a089b 100644 --- a/common-app-api/src/main/java/org/openecomp/sdc/be/config/ConfigurationManager.java +++ b/common-app-api/src/main/java/org/openecomp/sdc/be/config/ConfigurationManager.java @@ -7,9 +7,9 @@ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -32,122 +32,131 @@ import java.util.Map; public class ConfigurationManager implements FileChangeCallback, IEcompConfigurationManager { - ConfigurationSource configurationSource = null; - private static ConfigurationManager instance; - Map<String, Object> configurations = new HashMap<>(); + private ConfigurationSource configurationSource = null; + private static ConfigurationManager instance; - public ConfigurationManager(ConfigurationSource configurationSource) { - super(); - this.configurationSource = configurationSource; - loadConfigurationFiles(); - instance = this; - } + public Map<String, Object> getConfigurations() { + return configurations; + } - private void loadConfigurationFiles() { + public void setConfigurations(Map<String, Object> configurations) { + this.configurations = configurations; + } - loadConfigurationClass(Configuration.class); - loadConfigurationClass(ErrorConfiguration.class); - loadConfigurationClass(Neo4jErrorsConfiguration.class); - loadConfigurationClass(EcompErrorConfiguration.class); - loadConfigurationClass(DistributionEngineConfiguration.class); - } + private Map<String, Object> configurations = new HashMap<>(); - private <T extends BasicConfiguration> void loadConfigurationClass(Class<T> clazz) { - ConfigurationListener configurationListener = new ConfigurationListener(clazz, this); + public ConfigurationManager(ConfigurationSource configurationSource) { + super(); + this.configurationSource = configurationSource; + loadConfigurationFiles(); + instance = this; + } - T object = configurationSource.getAndWatchConfiguration(clazz, configurationListener); + private void loadConfigurationFiles() { - configurations.put(getKey(clazz), object); - } + loadConfigurationClass(Configuration.class); + loadConfigurationClass(ErrorConfiguration.class); + loadConfigurationClass(Neo4jErrorsConfiguration.class); + loadConfigurationClass(EcompErrorConfiguration.class); + loadConfigurationClass(DistributionEngineConfiguration.class); + } - private <T> String getKey(Class<T> class1) { + private <T extends BasicConfiguration> void loadConfigurationClass(Class<T> clazz) { + ConfigurationListener configurationListener = new ConfigurationListener(clazz, this); - return class1.getSimpleName(); + T object = configurationSource.getAndWatchConfiguration(clazz, configurationListener); - } + configurations.put(getKey(clazz), object); + } - public Configuration getConfiguration() { + private <T> String getKey(Class<T> class1) { - return (Configuration) configurations.get(getKey(Configuration.class)); + return class1.getSimpleName(); - } + } - public void setConfiguration(Configuration configuration) { + public Configuration getConfiguration() { - configurations.put(getKey(Configuration.class), configuration); + return (Configuration) configurations.get(getKey(Configuration.class)); - } + } - public void setErrorConfiguration(ErrorConfiguration configuration) { + public void setConfiguration(Configuration configuration) { - configurations.put(getKey(ErrorConfiguration.class), configuration); + configurations.put(getKey(Configuration.class), configuration); - } + } - public ErrorConfiguration getErrorConfiguration() { + public void setErrorConfiguration(ErrorConfiguration configuration) { - return (ErrorConfiguration) configurations.get(getKey(ErrorConfiguration.class)); + configurations.put(getKey(ErrorConfiguration.class), configuration); - } + } - public Neo4jErrorsConfiguration getNeo4jErrorsConfiguration() { - return (Neo4jErrorsConfiguration) configurations.get(getKey(Neo4jErrorsConfiguration.class)); - } + public ErrorConfiguration getErrorConfiguration() { - @Override - public EcompErrorConfiguration getEcompErrorConfiguration() { + return (ErrorConfiguration) configurations.get(getKey(ErrorConfiguration.class)); - return (EcompErrorConfiguration) configurations.get(getKey(EcompErrorConfiguration.class)); + } - } + public Neo4jErrorsConfiguration getNeo4jErrorsConfiguration() { + return (Neo4jErrorsConfiguration) configurations.get(getKey(Neo4jErrorsConfiguration.class)); + } - public Configuration getConfigurationAndWatch(ConfigurationListener configurationListener) { + @Override + public EcompErrorConfiguration getEcompErrorConfiguration() { - if (configurationListener != null) { + return (EcompErrorConfiguration) configurations.get(getKey(EcompErrorConfiguration.class)); - configurationSource.addWatchConfiguration(Configuration.class, configurationListener); + } - } - return (Configuration) configurations.get(getKey(Configuration.class)); + public Configuration getConfigurationAndWatch(ConfigurationListener configurationListener) { - } + if (configurationListener != null) { - public static ConfigurationManager getConfigurationManager() { - return instance; - } + configurationSource.addWatchConfiguration(Configuration.class, configurationListener); - public void reconfigure(BasicConfiguration obj) { + } + return (Configuration) configurations.get(getKey(Configuration.class)); - // if (obj != null) { + } - // if (obj instanceof Configuration) { - // configurations.put(getKey(Configuration.class), obj); - // } - // if (obj instanceof ErrorConfiguration) { - // configurations.put(getKey(ErrorConfiguration.class), obj); - // } - // - // if (obj instanceof EcompErrorConfiguration) { - // configurations.put(getKey(EcompErrorConfiguration.class), obj); - // } - // } + public static ConfigurationManager getConfigurationManager() { + return instance; + } - } + public void reconfigure(BasicConfiguration obj) { - /** - * FOR TEST ONLY - * - * @param ecompErrorConfiguration - */ - public void setEcompErrorConfiguration(EcompErrorConfiguration ecompErrorConfiguration) { + // if (obj != null) { - configurations.put(getKey(EcompErrorConfiguration.class), ecompErrorConfiguration); + // if (obj instanceof Configuration) { + // configurations.put(getKey(Configuration.class), obj); + // } + // if (obj instanceof ErrorConfiguration) { + // configurations.put(getKey(ErrorConfiguration.class), obj); + // } + // + // if (obj instanceof EcompErrorConfiguration) { + // configurations.put(getKey(EcompErrorConfiguration.class), obj); + // } + // } - } + } - public DistributionEngineConfiguration getDistributionEngineConfiguration() { + /** + * FOR TEST ONLY + * + * @param ecompErrorConfiguration + */ + public void setEcompErrorConfiguration(EcompErrorConfiguration ecompErrorConfiguration) { - return (DistributionEngineConfiguration) configurations.get(getKey(DistributionEngineConfiguration.class)); + configurations.put(getKey(EcompErrorConfiguration.class), ecompErrorConfiguration); - } + } + + public DistributionEngineConfiguration getDistributionEngineConfiguration() { + + return (DistributionEngineConfiguration) configurations.get(getKey(DistributionEngineConfiguration.class)); + + } } |