1 package org.oransc.policyagent.dmaap;
3 import java.util.Properties;
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;
11 public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
13 private final ApplicationConfig applicationConfig;
15 protected MRConsumerImpl consumer;
18 public DmaapMessageConsumerImpl(ApplicationConfig applicationConfig) {
19 this.applicationConfig = applicationConfig;
24 // TODO Auto-generated method stub
29 public void init(Properties baseProperties) {
30 Properties dmaapConsumerConfig = applicationConfig.getDmaapConsumerConfig();
31 // Initialize the DMAAP with the properties
32 // TODO Auto-generated method stub
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
45 public boolean isReady() {
46 // TODO Auto-generated method stub
51 public boolean isRunning() {
52 // TODO Auto-generated method stub
57 public void stopConsumer() {
58 // TODO Auto-generated method stub