1 package org.oransc.policyagent.dmaap;
3 import java.util.Properties;
5 import org.onap.dmaap.mr.client.impl.MRConsumerImpl;
7 public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
9 protected MRConsumerImpl consumer;
11 public DmaapMessageConsumerImpl() {
12 // TODO Auto-generated constructor stub
17 // TODO Auto-generated method stub
22 public void init(Properties baseProperties) {
23 // Initialize the DMAAP with the properties
24 // TODO Auto-generated method stub
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
37 public boolean isReady() {
38 // TODO Auto-generated method stub
43 public boolean isRunning() {
44 // TODO Auto-generated method stub
49 public void stopConsumer() {
50 // TODO Auto-generated method stub