ConsumerConfiguration.h

 
#ifndef PULSAR_CONSUMERCONFIGURATION_H_
#define PULSAR_CONSUMERCONFIGURATION_H_
 
#include <functional>
#include <memory>
#include <pulsar/Result.h>
#include <pulsar/ConsumerType.h>
#include <pulsar/Message.h>
#include <pulsar/Schema.h>
#include <pulsar/ConsumerCryptoFailureAction.h>
#include <pulsar/CryptoKeyReader.h>
#include <pulsar/InitialPosition.h>
 
#pragma GCC visibility push(default)
namespace pulsar {
 
class Consumer;
class PulsarWrapper;
 
typedef std::function<void(Result result)> ResultCallback;
typedef std::function<void(Result, const Message& msg)> ReceiveCallback;
 
typedef std::function<void(Consumer consumer, const Message& msg)> MessageListener;
 
class ConsumerConfigurationImpl;
 
class ConsumerConfiguration {
   public:
    ConsumerConfiguration();
    ~ConsumerConfiguration();
    ConsumerConfiguration(const ConsumerConfiguration&);
    ConsumerConfiguration& operator=(const ConsumerConfiguration&);
 
    ConsumerConfiguration& setSchema(const SchemaInfo& schemaInfo);
 
    const SchemaInfo& getSchema() const;
 
    ConsumerConfiguration& setConsumerType(ConsumerType consumerType);
    ConsumerType getConsumerType() const;
 
    ConsumerConfiguration& setMessageListener(MessageListener messageListener);
    MessageListener getMessageListener() const;
    bool hasMessageListener() const;
 
    void setReceiverQueueSize(int size);
    int getReceiverQueueSize() const;
 
    void setMaxTotalReceiverQueueSizeAcrossPartitions(int maxTotalReceiverQueueSizeAcrossPartitions);
 
    int getMaxTotalReceiverQueueSizeAcrossPartitions() const;
 
    void setConsumerName(const std::string&);
    const std::string& getConsumerName() const;
 
    void setUnAckedMessagesTimeoutMs(const uint64_t milliSeconds);
 
    long getUnAckedMessagesTimeoutMs() const;
 
    void setBrokerConsumerStatsCacheTimeInMs(const long cacheTimeInMs);
 
    long getBrokerConsumerStatsCacheTimeInMs() const;
 
    bool isEncryptionEnabled() const;
    const CryptoKeyReaderPtr getCryptoKeyReader() const;
    ConsumerConfiguration& setCryptoKeyReader(CryptoKeyReaderPtr cryptoKeyReader);
 
    ConsumerCryptoFailureAction getCryptoFailureAction() const;
    ConsumerConfiguration& setCryptoFailureAction(ConsumerCryptoFailureAction action);
 
    bool isReadCompacted() const;
    void setReadCompacted(bool compacted);
 
    void setPatternAutoDiscoveryPeriod(int periodInSeconds);
    int getPatternAutoDiscoveryPeriod() const;
 
    void setSubscriptionInitialPosition(InitialPosition subscriptionInitialPosition);
    InitialPosition getSubscriptionInitialPosition() 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;
 
    ConsumerConfiguration& setProperty(const std::string& name, const std::string& value);
 
    ConsumerConfiguration& setProperties(const std::map<std::string, std::string>& properties);
 
    friend class PulsarWrapper;
 
   private:
    std::shared_ptr<ConsumerConfigurationImpl> impl_;
};
}  // namespace pulsar
#pragma GCC visibility pop
#endif /* PULSAR_CONSUMERCONFIGURATION_H_ */