pulsar-client-cpp
Loading...
Searching...
No Matches
ConsumerEventListener.h
1
19#ifndef PULSAR_CONSUMEREVENTLISTENER_H_
20#define PULSAR_CONSUMEREVENTLISTENER_H_
21
22#include <pulsar/defines.h>
23
24namespace pulsar {
25
26class Consumer;
27
28class PULSAR_PUBLIC ConsumerEventListener {
29 public:
30 virtual ~ConsumerEventListener(){};
37 virtual void becameActive(Consumer consumer, int partitionId) = 0;
38
46 virtual void becameInactive(Consumer consumer, int partitionId) = 0;
47};
48} // namespace pulsar
49#endif /* PULSAR_CONSUMEREVENTLISTENER_H_ */
Definition ConsumerEventListener.h:28
virtual void becameInactive(Consumer consumer, int partitionId)=0
Notified when the consumer group is changed, and the consumer is still inactive or becomes inactive.
virtual void becameActive(Consumer consumer, int partitionId)=0
Notified when the consumer group is changed, and the consumer becomes active.
Definition Consumer.h:37
Definition Authentication.h:31