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

   1 package org.oransc.policyagent.dmaap;
   2
   3 import java.util.Properties;
   4
   5 /**
   6  * The Dmaap consumer which has the base methods to be implemented by any class
   7  * which implements this interface
   8  *
   9  */
  10 public interface DmaapMessageConsumer extends Runnable {
  11
  12     public void init(Properties baseProperties);
  13
  14     public abstract void processMsg(String msg) throws Exception;
  15
  16     public boolean isReady();
  17
  18     public boolean isRunning();
  19
  20     public void stopConsumer();
  21
  22 }