19#ifndef PULSAR_READER_HPP_
20#define PULSAR_READER_HPP_
22#include <pulsar/Message.h>
23#include <pulsar/ReaderConfiguration.h>
24#include <pulsar/defines.h>
31typedef std::function<void(
Result result,
bool hasMessageAvailable)> HasMessageAvailableCallback;
32typedef std::function<void(
Result result,
const Message& message)> ReadNextCallback;
160 typedef std::shared_ptr<ReaderImpl> ReaderImplPtr;
162 explicit Reader(ReaderImplPtr);
164 friend class PulsarFriend;
165 friend class PulsarWrapper;
166 friend class ReaderImpl;
167 friend class TableViewImpl;
168 friend class ReaderTest;
Definition MessageId.h:34
void hasMessageAvailableAsync(HasMessageAvailableCallback callback)
Result readNext(Message &msg)
const std::string & getTopic() const
void readNextAsync(ReadNextCallback callback)
void getLastMessageIdAsync(GetLastMessageIdCallback callback)
void closeAsync(ResultCallback callback)
Result readNext(Message &msg, int timeoutMs)
Result seek(const MessageId &msgId)
Result hasMessageAvailable(bool &hasMessageAvailable)
Result getLastMessageId(MessageId &messageId)
void seekAsync(const MessageId &msgId, ResultCallback callback)
void seekAsync(uint64_t timestamp, ResultCallback callback)
Result seek(uint64_t timestamp)
Definition Authentication.h:31
std::function< void(Result result)> ResultCallback
Callback definition for non-data operation.
Definition ConsumerConfiguration.h:50
Result
Definition Result.h:32