aboutsummaryrefslogtreecommitdiffstats
path: root/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java
diff options
context:
space:
mode:
Diffstat (limited to 'UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java')
-rw-r--r--UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java27
1 files changed, 20 insertions, 7 deletions
diff --git a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java
index 34bbc8e..11bba61 100644
--- a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java
+++ b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/DmaapConfig.java
@@ -30,15 +30,19 @@ import org.springframework.stereotype.Component;
@ConfigurationProperties
public class DmaapConfig {
- @Value("${mr.hostname}")
+ @Value("${mr.dmaaphost}")
@NotEmpty
- private String hostname;
+ private String dmaaphost;
// default port number
@Value("${mr.DEFAULT_PORT_NUMBER}")
@NotEmpty
private int DEFAULT_PORT_NUMBER;
+ @Value("${mr.POLLING_INTERVAL}")
+ @NotEmpty
+ private int pollingInterval;
+
// default to no username
@Value("${mr.DEFAULT_USER_NAME}")
private String DEFAULT_USER_NAME;
@@ -124,12 +128,12 @@ public class DmaapConfig {
@NotEmpty
private String subcriberSUBSCRIBER_MSG_LIMIT_QUERY_PARAM_NAME;
- public void setHostname(String hostname) {
- this.hostname = hostname;
+ public void setDmaaphost(String dmaaphost) {
+ this.dmaaphost = dmaaphost;
}
-
- public String getHostname() {
- return hostname;
+
+ public String getDmaaphost() {
+ return dmaaphost;
}
public int getDEFAULT_PORT_NUMBER() {
@@ -285,4 +289,13 @@ public class DmaapConfig {
this.subcriberSUBSCRIBER_MSG_LIMIT_QUERY_PARAM_NAME = subcriberSUBSCRIBER_MSG_LIMIT_QUERY_PARAM_NAME;
}
+ public int getPollingInterval() {
+ return pollingInterval;
+ }
+
+ public void setPollingInterval(int pollingInterval) {
+ this.pollingInterval = pollingInterval;
+ }
+
+
}