Producer.h

 
#ifndef PRODUCER_HPP_
#define PRODUCER_HPP_
 
#include <pulsar/defines.h>
#include <pulsar/ProducerConfiguration.h>
#include <memory>
#include <stdint.h>
 
namespace pulsar {
class ProducerImplBase;
class PulsarWrapper;
class PulsarFriend;
 
typedef std::function<void(Result)> FlushCallback;
typedef std::shared_ptr<ProducerImplBase> ProducerImplBasePtr;
 
class PULSAR_PUBLIC Producer {
   public:
    Producer();
 
    const std::string& getTopic() const;
 
    const std::string& getProducerName() const;
 
    Result send(const Message& msg);
 
    Result send(const Message& msg, MessageId& messageId);
 
    void sendAsync(const Message& msg, SendCallback callback);
 
    Result flush();
 
    void flushAsync(FlushCallback callback);
 
    int64_t getLastSequenceId() const;
 
    const std::string& getSchemaVersion() const;
 
    Result close();
 
    void closeAsync(CloseCallback callback);
 
    bool isConnected() const;
 
   private:
    explicit Producer(ProducerImplBasePtr);
 
    friend class ClientImpl;
    friend class PulsarFriend;
    friend class PulsarWrapper;
 
    ProducerImplBasePtr impl_;
 
    // For unit test case BatchMessageTest::producerFailureResult only
    void producerFailMessages(Result result);
};
}  // namespace pulsar
 
#endif /* PRODUCER_HPP_ */