X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fdmaap%2FDmaapMessageConsumerImpl.java;h=30444e201ef8cf85e12d7c34b1096d3222016667;hb=777b07b0c5ee62ebee9526e634bee7ae3f82640c;hp=b64a82244953ab2878bf41e1a62a2132601c9974;hpb=e8c7fa0b02b0918b3b56a1fc162968a3eef282dc;p=nonrtric.git

diff --git a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
index b64a8224..30444e20 100644
--- a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
+++ b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
@@ -3,13 +3,20 @@ package org.oransc.policyagent.dmaap;
 import java.util.Properties;
 
 import org.onap.dmaap.mr.client.impl.MRConsumerImpl;
+import org.oransc.policyagent.configuration.ApplicationConfig;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
 
+@Component
 public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
 
+    private final ApplicationConfig applicationConfig;
+
 	protected MRConsumerImpl consumer;
-	
-	public DmaapMessageConsumerImpl() {
-		// TODO Auto-generated constructor stub
+
+	@Autowired
+	public DmaapMessageConsumerImpl(ApplicationConfig applicationConfig) {
+		this.applicationConfig = applicationConfig;
 	}
 
 	@Override
@@ -20,6 +27,7 @@ public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
 
 	@Override
 	public void init(Properties baseProperties) {
+	    Properties dmaapConsumerConfig = applicationConfig.getDmaapConsumerConfig();
 		// Initialize the DMAAP with the properties
 		// TODO Auto-generated method stub