42be12d3a329bca4434b4c352f81d0d21ca30427
[nonrtric.git] / 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 }