policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java

   1 package org.oransc.policyagent.dmaap;
   2
   3 import java.util.Properties;
   4
   5 import org.onap.dmaap.mr.client.impl.MRConsumerImpl;
   6 import org.oransc.policyagent.configuration.ApplicationConfig;
   7 import org.springframework.beans.factory.annotation.Autowired;
   8 import org.springframework.stereotype.Component;
   9
  10 @Component
  11 public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
  12
  13     private final ApplicationConfig applicationConfig;
  14
  15     protected MRConsumerImpl consumer;
  16
  17     @Autowired
  18     public DmaapMessageConsumerImpl(ApplicationConfig applicationConfig) {
  19         this.applicationConfig = applicationConfig;
  20     }
  21
  22     @Override
  23     public void run() {
  24         // TODO Auto-generated method stub
  25
  26     }
  27
  28     @Override
  29     public void init(Properties baseProperties) {
  30         Properties dmaapConsumerConfig = applicationConfig.getDmaapConsumerConfig();
  31         // Initialize the DMAAP with the properties
  32         // TODO Auto-generated method stub
  33
  34     }
  35
  36     @Override
  37     public void processMsg(String msg) throws Exception {
  38         // Call the Controller once you get the message from DMAAP
  39         // Call the concurrent Task executor to handle the incoming request
  40         // TODO Auto-generated method stub
  41
  42     }
  43
  44     @Override
  45     public boolean isReady() {
  46         // TODO Auto-generated method stub
  47         return false;
  48     }
  49
  50     @Override
  51     public boolean isRunning() {
  52         // TODO Auto-generated method stub
  53         return false;
  54     }
  55
  56     @Override
  57     public void stopConsumer() {
  58         // TODO Auto-generated method stub
  59
  60     }
  61
  62 }