ReaderConfiguration.h

 
#ifndef PULSAR_READER_CONFIGURATION_H_
#define PULSAR_READER_CONFIGURATION_H_
 
#include <functional>
#include <memory>
#include <pulsar/Result.h>
#include <pulsar/Message.h>
#include <pulsar/Schema.h>
 
#pragma GCC visibility push(default)
namespace pulsar {
 
class Reader;
class PulsarWrapper;
 
typedef std::function<void(Result result)> ResultCallback;
 
typedef std::function<void(Reader reader, const Message& msg)> ReaderListener;
 
class ReaderConfigurationImpl;
 
class ReaderConfiguration {
   public:
    ReaderConfiguration();
    ~ReaderConfiguration();
    ReaderConfiguration(const ReaderConfiguration&);
    ReaderConfiguration& operator=(const ReaderConfiguration&);
 
    ReaderConfiguration& setSchema(const SchemaInfo& schemaInfo);
 
    const SchemaInfo& getSchema() const;
 
    ReaderConfiguration& setReaderListener(ReaderListener listener);
    ReaderListener getReaderListener() const;
    bool hasReaderListener() const;
 
    void setReceiverQueueSize(int size);
    int getReceiverQueueSize() const;
 
    void setReaderName(const std::string& readerName);
    const std::string& getReaderName() const;
 
    void setSubscriptionRolePrefix(const std::string& subscriptionRolePrefix);
    const std::string& getSubscriptionRolePrefix() const;
 
    void setReadCompacted(bool compacted);
    bool isReadCompacted() const;
 
   private:
    std::shared_ptr<ReaderConfigurationImpl> impl_;
};
}  // namespace pulsar
#pragma GCC visibility pop
#endif /* PULSAR_READER_CONFIGURATION_H_ */