+/**
+ * The Dmaap consumer which has the base methods to be implemented by any class which implements this interface
+ *
+ */
+public interface DmaapMessageConsumer {
+
+ /**
+ * The init method creates the MRConsumer with the properties passed from the Application Config
+ *
+ * @param properties
+ */
+ public void init();
+
+ /**
+ * This method process the message and call the respective Controller
+ *
+ * @param msg
+ * @throws Exception
+ */
+ public abstract void processMsg(String msg) throws Exception;
+
+ /**
+ * To check whether the DMAAP Listner is alive
+ *
+ * @return boolean
+ */
+ public boolean isAlive();
+
+ /**
+ * To Stop the DMAAP Listener
+ */
+ public void stopConsumer();
+
+ /**
+ * It's a infinite loop run every configured seconds to fetch the message from DMAAP. This method can be stop by
+ * setting the alive flag to false
+ */
+ public void run();