ProducerInterceptor.h

 
#ifndef PULSAR_PRODUCER_INTERCEPTOR_H
#define PULSAR_PRODUCER_INTERCEPTOR_H
 
#include <pulsar/Message.h>
#include <pulsar/Result.h>
#include <pulsar/defines.h>
 
namespace pulsar {
 
class Producer;
 
class PULSAR_PUBLIC ProducerInterceptor {
   public:
    virtual ~ProducerInterceptor() {}
 
    virtual void close() {}
 
    virtual Message beforeSend(const Producer& producer, const Message& message) = 0;
 
    virtual void onSendAcknowledgement(const Producer& producer, Result result, const Message& message,
                                       const MessageId& messageID) = 0;
 
    virtual void onPartitionsChange(const std::string& topicName, int partitions) {}
};
 
typedef std::shared_ptr<ProducerInterceptor> ProducerInterceptorPtr;
}  // namespace pulsar
 
#endif  // PULSAR_PRODUCER_INTERCEPTOR_H