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
   7 public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
   8
   9         protected MRConsumerImpl consumer;
  10
  11         public DmaapMessageConsumerImpl() {
  12                 // TODO Auto-generated constructor stub
  13         }
  14
  15         @Override
  16         public void run() {
  17                 // TODO Auto-generated method stub
  18
  19         }
  20
  21         @Override
  22         public void init(Properties baseProperties) {
  23                 // Initialize the DMAAP with the properties
  24                 // TODO Auto-generated method stub
  25
  26         }
  27
  28         @Override
  29         public void processMsg(String msg) throws Exception {
  30                 // Call the Controller once you get the message from DMAAP
  31                 // Call the concurrent Task executor to handle the incoming request
  32                 // TODO Auto-generated method stub
  33
  34         }
  35
  36         @Override
  37         public boolean isReady() {
  38                 // TODO Auto-generated method stub
  39                 return false;
  40         }
  41
  42         @Override
  43         public boolean isRunning() {
  44                 // TODO Auto-generated method stub
  45                 return false;
  46         }
  47
  48         @Override
  49         public void stopConsumer() {
  50                 // TODO Auto-generated method stub
  51
  52         }
  53
  54 }