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=1e8c6d472cf6f37b7c92c576388ba73395f7e0fe;hb=refs%2Fchanges%2F83%2F2383%2F3;hp=1ed3fdb2b70706ac54c958eaa3e308973ef743e0;hpb=c3ed1a5199e3f5f539cc813b9a383dd156fed2e2;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 1ed3fdb2..1e8c6d47 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 @@ -29,6 +29,8 @@ 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; @@ -40,9 +42,20 @@ public class ApplicationConfig { @NotEmpty private String filepath; + @NotEmpty + private String a1ControllerBaseUrl; + + @NotEmpty + private String a1ControllerUsername; + + @NotEmpty + private String a1ControllerPassword; + private Collection observers = new Vector<>(); private Map ricConfigs = new HashMap<>(); + @Getter private Properties dmaapPublisherConfig; + @Getter private Properties dmaapConsumerConfig; @Autowired @@ -53,6 +66,18 @@ public class ApplicationConfig { return this.filepath; } + public String getA1ControllerBaseUrl() { + return this.a1ControllerBaseUrl; + } + + public String getA1ControllerUsername() { + return this.a1ControllerUsername; + } + + public String getA1ControllerPassword() { + return this.a1ControllerPassword; + } + /* * Do not remove, used by framework! */ @@ -60,6 +85,18 @@ public class ApplicationConfig { this.filepath = filepath; } + public synchronized void setA1ControllerBaseUrl(String a1ControllerBaseUrl) { + this.a1ControllerBaseUrl = a1ControllerBaseUrl; + } + + public synchronized void setA1ControllerUsername(String a1ControllerUsername) { + this.a1ControllerUsername = a1ControllerUsername; + } + + public synchronized void setA1ControllerPassword(String a1ControllerPassword) { + this.a1ControllerPassword = a1ControllerPassword; + } + public synchronized Collection getRicConfigs() { return this.ricConfigs.values(); } @@ -73,14 +110,6 @@ public class ApplicationConfig { throw new ServiceException("Could not find ric: " + ricName); } - public Properties getDmaapPublisherConfig() { - return dmaapConsumerConfig; - } - - public Properties getDmaapConsumerConfig() { - return dmaapConsumerConfig; - } - public static enum RicConfigUpdate { ADDED, CHANGED, REMOVED } @@ -114,7 +143,7 @@ public class ApplicationConfig { newRicConfigs.put(newConfig.name(), newConfig); notifications.add(new Notification(newConfig, RicConfigUpdate.ADDED)); this.ricConfigs.remove(newConfig.name()); - } else if (!newConfig.equals(newConfig)) { + } else if (!newConfig.equals(oldConfig)) { notifications.add(new Notification(newConfig, RicConfigUpdate.CHANGED)); newRicConfigs.put(newConfig.name(), newConfig); this.ricConfigs.remove(newConfig.name());