X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fconfiguration%2FApplicationConfig.java;h=1dd850be6be4fb84971cf43895cf2758155bcf14;hb=1722366b9678eb50753db8c020c230afe25cd1f8;hp=1e8c6d472cf6f37b7c92c576388ba73395f7e0fe;hpb=0da7354bf7548829a7152dfa0276710dbbe00b7b;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfig.java b/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfig.java index 1e8c6d47..1dd850be 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfig.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfig.java @@ -20,19 +20,15 @@ package org.oransc.policyagent.configuration; +import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; import java.util.Map; import java.util.Properties; -import java.util.Vector; - import javax.validation.constraints.NotEmpty; import javax.validation.constraints.NotNull; - import lombok.Getter; - import org.oransc.policyagent.exceptions.ServiceException; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; @@ -51,17 +47,13 @@ public class ApplicationConfig { @NotEmpty private String a1ControllerPassword; - private Collection observers = new Vector<>(); + private Collection observers = new ArrayList<>(); private Map ricConfigs = new HashMap<>(); @Getter private Properties dmaapPublisherConfig; @Getter private Properties dmaapConsumerConfig; - @Autowired - public ApplicationConfig() { - } - public String getLocalConfigurationFilePath() { return this.filepath; } @@ -110,7 +102,7 @@ public class ApplicationConfig { throw new ServiceException("Could not find ric: " + ricName); } - public static enum RicConfigUpdate { + public enum RicConfigUpdate { ADDED, CHANGED, REMOVED } @@ -134,8 +126,12 @@ public class ApplicationConfig { public void setConfiguration(@NotNull Collection ricConfigs, Properties dmaapPublisherConfig, Properties dmaapConsumerConfig) { - Collection notifications = new Vector<>(); + + Collection notifications = new ArrayList<>(); synchronized (this) { + this.dmaapPublisherConfig = dmaapPublisherConfig; + this.dmaapConsumerConfig = dmaapConsumerConfig; + Map newRicConfigs = new HashMap<>(); for (RicConfig newConfig : ricConfigs) { RicConfig oldConfig = this.ricConfigs.get(newConfig.name()); @@ -156,10 +152,8 @@ public class ApplicationConfig { } this.ricConfigs = newRicConfigs; } - notifyObservers(notifications); - this.dmaapPublisherConfig = dmaapPublisherConfig; - this.dmaapConsumerConfig = dmaapConsumerConfig; + notifyObservers(notifications); } private void notifyObservers(Collection notifications) {