20#ifndef PULSAR_PRODUCER_INTERCEPTOR_H
21#define PULSAR_PRODUCER_INTERCEPTOR_H
23#include <pulsar/Message.h>
24#include <pulsar/Result.h>
25#include <pulsar/defines.h>
111typedef std::shared_ptr<ProducerInterceptor> ProducerInterceptorPtr;
Definition MessageId.h:34
Definition ProducerInterceptor.h:42
virtual void close()
Definition ProducerInterceptor.h:49
virtual void onPartitionsChange(const std::string &topicName, int partitions)
Definition ProducerInterceptor.h:108
virtual void onSendAcknowledgement(const Producer &producer, Result result, const Message &message, const MessageId &messageID)=0
virtual Message beforeSend(const Producer &producer, const Message &message)=0
Definition Authentication.h:31
Result
Definition Result.h:32