ConsumerEventListener.h

 
#ifndef PULSAR_CONSUMEREVENTLISTENER_H_
#define PULSAR_CONSUMEREVENTLISTENER_H_
 
#include <pulsar/defines.h>
 
namespace pulsar {
 
class Consumer;
 
class PULSAR_PUBLIC ConsumerEventListener {
   public:
    virtual ~ConsumerEventListener(){};
    virtual void becameActive(Consumer consumer, int partitionId) = 0;
 
    virtual void becameInactive(Consumer consumer, int partitionId) = 0;
};
}  // namespace pulsar
#endif /* PULSAR_CONSUMEREVENTLISTENER_H_ */