Producer.h

 
#ifndef PRODUCER_HPP_
#define PRODUCER_HPP_
 
#include <pulsar/ProducerConfiguration.h>
#include <memory>
#include <stdint.h>
 
#pragma GCC visibility push(default)
 
namespace pulsar {
class ProducerImplBase;
class PulsarWrapper;
class PulsarFriend;
 
typedef std::function<void(Result)> FlushCallback;
typedef std::shared_ptr<ProducerImplBase> ProducerImplBasePtr;
 
class Producer {
   public:
    Producer();
 
    const std::string& getTopic() const;
 
    const std::string& getProducerName() const;
 
    Result send(const Message& msg);
 
    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);
 
   private:
    explicit Producer(ProducerImplBasePtr);
 
    friend class ClientImpl;
    friend class PulsarFriend;
    friend class PulsarWrapper;
 
    ProducerImplBasePtr impl_;
};
}  // namespace pulsar
 
#pragma GCC visibility pop
 
#endif /* PRODUCER_HPP_ */