ConsumerInterceptor.h

 
#ifndef PULSAR_CPP_CONSUMER_INTERCEPTOR_H
#define PULSAR_CPP_CONSUMER_INTERCEPTOR_H
 
#include <pulsar/Message.h>
#include <pulsar/Result.h>
#include <pulsar/defines.h>
 
#include <set>
 
namespace pulsar {
 
class Consumer;
 
class PULSAR_PUBLIC ConsumerInterceptor {
   public:
    virtual ~ConsumerInterceptor() {}
    virtual void close() {}
 
    virtual Message beforeConsume(const Consumer& consumer, const Message& message) = 0;
 
    virtual void onAcknowledge(const Consumer& consumer, Result result, const MessageId& messageID) = 0;
 
    virtual void onAcknowledgeCumulative(const Consumer& consumer, Result result,
                                         const MessageId& messageID) = 0;
 
    virtual void onNegativeAcksSend(const Consumer& consumer, const std::set<MessageId>& messageIds) = 0;
};
 
typedef std::shared_ptr<ConsumerInterceptor> ConsumerInterceptorPtr;
}  // namespace pulsar
 
#endif  // PULSAR_CPP_CONSUMER_INTERCEPTOR_H