package org.oransc.policyagent.dmaap;
-import java.util.Properties;
-
/**
* The Dmaap consumer which has the base methods to be implemented by any class which implements this interface
*
*
* @param properties
*/
- public void init(Properties properties);
+ public void init();
/**
* This method process the message and call the respective Controller
*/
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