ClientConfiguration.h

 
#ifndef PULSAR_CLIENTCONFIGURATION_H_
#define PULSAR_CLIENTCONFIGURATION_H_
 
#include <pulsar/Authentication.h>
#include <pulsar/Logger.h>
 
#pragma GCC visibility push(default)
namespace pulsar {
class PulsarWrapper;
class ClientConfigurationImpl;
class ClientConfiguration {
   public:
    ClientConfiguration();
    ~ClientConfiguration();
    ClientConfiguration(const ClientConfiguration&);
    ClientConfiguration& operator=(const ClientConfiguration&);
 
    ClientConfiguration& setAuth(const AuthenticationPtr& authentication);
 
    const 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(LoggerFactoryPtr loggerFactory);
 
    LoggerFactoryPtr getLogger() const;
 
    ClientConfiguration& setUseTls(bool useTls);
    bool isUseTls() const;
 
    ClientConfiguration& setTlsTrustCertsFilePath(const std::string& tlsTrustCertsFilePath);
    std::string getTlsTrustCertsFilePath() const;
 
    ClientConfiguration& setTlsAllowInsecureConnection(bool allowInsecure);
    bool isTlsAllowInsecureConnection() const;
 
    ClientConfiguration& setValidateHostName(bool validateHostName);
    bool isValidateHostName() const;
 
    /*
     * Initialize stats interval in seconds. Stats are printed and reset after every 'statsIntervalInSeconds'.
     * Set to 0 in order to disable stats collection.
     */
    ClientConfiguration& setStatsIntervalInSeconds(const unsigned int&);
 
    /*
     * Get the stats interval set in the client.
     */
    const unsigned int& getStatsIntervalInSeconds() const;
 
    friend class ClientImpl;
    friend class PulsarWrapper;
 
   private:
    const AuthenticationPtr& getAuthPtr() const;
    std::shared_ptr<ClientConfigurationImpl> impl_;
};
}  // namespace pulsar
 
#pragma GCC visibility pop
#endif /* PULSAR_CLIENTCONFIGURATION_H_ */