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 }