20#ifndef PULSAR_CPP_CONSUMER_INTERCEPTOR_H
21#define PULSAR_CPP_CONSUMER_INTERCEPTOR_H
23#include <pulsar/Message.h>
24#include <pulsar/Result.h>
25#include <pulsar/defines.h>
118typedef std::shared_ptr<ConsumerInterceptor> ConsumerInterceptorPtr;
Definition ConsumerInterceptor.h:43
virtual Message beforeConsume(const Consumer &consumer, const Message &message)=0
virtual void onNegativeAcksSend(const Consumer &consumer, const std::set< MessageId > &messageIds)=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 close()
Definition ConsumerInterceptor.h:49
Definition MessageId.h:34
Definition Authentication.h:31
Result
Definition Result.h:32