ReaderConfiguration.h

 
#ifndef PULSAR_READER_CONFIGURATION_H_
#define PULSAR_READER_CONFIGURATION_H_
 
#include <pulsar/ConsumerCryptoFailureAction.h>
#include <pulsar/CryptoKeyReader.h>
#include <pulsar/Message.h>
#include <pulsar/Result.h>
#include <pulsar/Schema.h>
#include <pulsar/defines.h>
 
#include <functional>
#include <memory>
 
namespace pulsar {
 
class Reader;
class PulsarWrapper;
 
typedef std::function<void(Result result)> ResultCallback;
typedef std::function<void(Result result, MessageId messageId)> GetLastMessageIdCallback;
 
typedef std::function<void(Reader reader, const Message& msg)> ReaderListener;
 
struct ReaderConfigurationImpl;
 
class PULSAR_PUBLIC 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;
 
    void setInternalSubscriptionName(std::string internalSubscriptionName);
 
    const std::string& getInternalSubscriptionName() const;
 
    void setUnAckedMessagesTimeoutMs(const uint64_t milliSeconds);
 
    long getUnAckedMessagesTimeoutMs() const;
 
    void setTickDurationInMs(const uint64_t milliSeconds);
 
    long getTickDurationInMs() const;
 
    void setAckGroupingTimeMs(long ackGroupingMillis);
 
    long getAckGroupingTimeMs() const;
 
    void setAckGroupingMaxSize(long maxGroupingSize);
 
    long getAckGroupingMaxSize() const;
 
    bool isEncryptionEnabled() const;
 
    const CryptoKeyReaderPtr getCryptoKeyReader() const;
 
    ReaderConfiguration& setCryptoKeyReader(CryptoKeyReaderPtr cryptoKeyReader);
 
    ConsumerCryptoFailureAction getCryptoFailureAction() const;
 
    ReaderConfiguration& setCryptoFailureAction(ConsumerCryptoFailureAction action);
 
    ReaderConfiguration& setStartMessageIdInclusive(bool startMessageIdInclusive);
 
    bool isStartMessageIdInclusive() const;
 
    bool hasProperty(const std::string& name) const;
 
    const std::string& getProperty(const std::string& name) const;
 
    std::map<std::string, std::string>& getProperties() const;
 
    ReaderConfiguration& setProperty(const std::string& name, const std::string& value);
 
    ReaderConfiguration& setProperties(const std::map<std::string, std::string>& properties);
 
   private:
    std::shared_ptr<ReaderConfigurationImpl> impl_;
};
}  // namespace pulsar
#endif /* PULSAR_READER_CONFIGURATION_H_ */