Add A1 controller client in policy-agent

[nonrtric.git] / policy-agent / src / main / java / org / oransc / policyagent / dmaap / DmaapMessageConsumerImpl.java

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 30444e2..63de197 100644 (file)
--- a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
+++ b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
@@ -12,51 +12,51 @@ public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
 
     private final ApplicationConfig applicationConfig;
 
-       protected MRConsumerImpl consumer;
+    protected MRConsumerImpl consumer;
 
-       @Autowired
-       public DmaapMessageConsumerImpl(ApplicationConfig applicationConfig) {
-               this.applicationConfig = applicationConfig;
-       }
+    @Autowired
+    public DmaapMessageConsumerImpl(ApplicationConfig applicationConfig) {
+        this.applicationConfig = applicationConfig;
+    }
 
-       @Override
-       public void run() {
-               // TODO Auto-generated method stub
+    @Override
+    public void run() {
+        // TODO Auto-generated method stub
 
-       }
+    }
 
-       @Override
-       public void init(Properties baseProperties) {
-           Properties dmaapConsumerConfig = applicationConfig.getDmaapConsumerConfig();
-               // Initialize the DMAAP with the properties
-               // TODO Auto-generated method stub
+    @Override
+    public void init(Properties baseProperties) {
+        Properties dmaapConsumerConfig = applicationConfig.getDmaapConsumerConfig();
+        // Initialize the DMAAP with the properties
+        // TODO Auto-generated method stub
 
-       }
+    }
 
-       @Override
-       public void processMsg(String msg) throws Exception {
-               // Call the Controller once you get the message from DMAAP
-               // Call the concurrent Task executor to handle the incoming request
-               // TODO Auto-generated method stub
+    @Override
+    public void processMsg(String msg) throws Exception {
+        // Call the Controller once you get the message from DMAAP
+        // Call the concurrent Task executor to handle the incoming request
+        // TODO Auto-generated method stub
 
-       }
+    }
 
-       @Override
-       public boolean isReady() {
-               // TODO Auto-generated method stub
-               return false;
-       }
+    @Override
+    public boolean isReady() {
+        // TODO Auto-generated method stub
+        return false;
+    }
 
-       @Override
-       public boolean isRunning() {
-               // TODO Auto-generated method stub
-               return false;
-       }
+    @Override
+    public boolean isRunning() {
+        // TODO Auto-generated method stub
+        return false;
+    }
 
-       @Override
-       public void stopConsumer() {
-               // TODO Auto-generated method stub
+    @Override
+    public void stopConsumer() {
+        // TODO Auto-generated method stub
 
-       }
+    }
 
 }