Reader.h

 
#ifndef PULSAR_READER_HPP_
#define PULSAR_READER_HPP_
 
#include <pulsar/Message.h>
#include <pulsar/ReaderConfiguration.h>
#include <pulsar/defines.h>
 
namespace pulsar {
class PulsarWrapper;
class PulsarFriend;
class ReaderImpl;
 
typedef std::function<void(Result result, bool hasMessageAvailable)> HasMessageAvailableCallback;
typedef std::function<void(Result result, const Message& message)> ReadNextCallback;
 
class PULSAR_PUBLIC Reader {
   public:
    Reader();
 
    const std::string& getTopic() const;
 
    Result readNext(Message& msg);
 
    Result readNext(Message& msg, int timeoutMs);
 
    void readNextAsync(const ReadNextCallback& callback);
 
    Result close();
 
    void closeAsync(const ResultCallback& callback);
 
    void hasMessageAvailableAsync(const HasMessageAvailableCallback& callback);
 
    Result hasMessageAvailable(bool& hasMessageAvailable);
 
    Result seek(const MessageId& msgId);
 
    Result seek(uint64_t timestamp);
 
    void seekAsync(const MessageId& msgId, const ResultCallback& callback);
 
    void seekAsync(uint64_t timestamp, const ResultCallback& callback);
 
    bool isConnected() const;
 
    void getLastMessageIdAsync(const GetLastMessageIdCallback& callback);
 
    Result getLastMessageId(MessageId& messageId);
 
   private:
    typedef std::shared_ptr<ReaderImpl> ReaderImplPtr;
    ReaderImplPtr impl_;
    explicit Reader(const ReaderImplPtr&);
 
    friend class PulsarFriend;
    friend class PulsarWrapper;
    friend class ReaderImpl;
    friend class TableViewImpl;
    friend class ReaderTest;
};
}  // namespace pulsar
 
#endif /* PULSAR_READER_HPP_ */