ClientConfiguration.h

 
#ifndef PULSAR_CLIENTCONFIGURATION_H_
#define PULSAR_CLIENTCONFIGURATION_H_
 
#include <pulsar/defines.h>
#include <pulsar/Authentication.h>
#include <pulsar/Logger.h>
 
namespace pulsar {
class PulsarWrapper;
struct ClientConfigurationImpl;
class PULSAR_PUBLIC ClientConfiguration {
   public:
    ClientConfiguration();
    ~ClientConfiguration();
    ClientConfiguration(const ClientConfiguration&);
    ClientConfiguration& operator=(const ClientConfiguration&);
 
    ClientConfiguration& setMemoryLimit(uint64_t memoryLimitBytes);
 
    uint64_t getMemoryLimit() const;
 
    ClientConfiguration& setAuth(const AuthenticationPtr& authentication);
 
    Authentication& getAuth() const;
 
    ClientConfiguration& setOperationTimeoutSeconds(int timeout);
 
    int getOperationTimeoutSeconds() const;
 
    ClientConfiguration& setIOThreads(int threads);
 
    int getIOThreads() const;
 
    ClientConfiguration& setMessageListenerThreads(int threads);
 
    int getMessageListenerThreads() const;
 
    ClientConfiguration& setConcurrentLookupRequest(int concurrentLookupRequest);
 
    int getConcurrentLookupRequest() const;
 
    ClientConfiguration& setLogConfFilePath(const std::string& logConfFilePath);
 
    const std::string& getLogConfFilePath() const;
 
    ClientConfiguration& setLogger(LoggerFactory* loggerFactory);
 
    ClientConfiguration& setUseTls(bool useTls);
 
    bool isUseTls() const;
 
    ClientConfiguration& setTlsPrivateKeyFilePath(const std::string& tlsKeyFilePath);
 
    const std::string& getTlsPrivateKeyFilePath() const;
 
    ClientConfiguration& setTlsCertificateFilePath(const std::string& tlsCertificateFilePath);
 
    const std::string& getTlsCertificateFilePath() const;
 
    ClientConfiguration& setTlsTrustCertsFilePath(const std::string& tlsTrustCertsFilePath);
 
    const std::string& getTlsTrustCertsFilePath() const;
 
    ClientConfiguration& setTlsAllowInsecureConnection(bool allowInsecure);
 
    bool isTlsAllowInsecureConnection() const;
 
    ClientConfiguration& setValidateHostName(bool validateHostName);
 
    bool isValidateHostName() const;
 
    ClientConfiguration& setListenerName(const std::string& listenerName);
 
    const std::string& getListenerName() const;
 
    ClientConfiguration& setStatsIntervalInSeconds(const unsigned int&);
 
    const unsigned int& getStatsIntervalInSeconds() const;
 
    ClientConfiguration& setPartititionsUpdateInterval(unsigned int intervalInSeconds);
 
    unsigned int getPartitionsUpdateInterval() const;
 
    ClientConfiguration& setConnectionTimeout(int timeoutMs);
 
    int getConnectionTimeout() const;
 
    friend class ClientImpl;
    friend class PulsarWrapper;
 
   private:
    const AuthenticationPtr& getAuthPtr() const;
    std::shared_ptr<ClientConfigurationImpl> impl_;
};
}  // namespace pulsar
 
#endif /* PULSAR_CLIENTCONFIGURATION_H_ */