19 #ifndef PULSAR_READER_CONFIGURATION_H_
20 #define PULSAR_READER_CONFIGURATION_H_
22 #include <pulsar/ConsumerCryptoFailureAction.h>
23 #include <pulsar/CryptoKeyReader.h>
24 #include <pulsar/Message.h>
25 #include <pulsar/Result.h>
26 #include <pulsar/Schema.h>
27 #include <pulsar/defines.h>
39 typedef std::function<void(
Result result, MessageId messageId)> GetLastMessageIdCallback;
44 struct ReaderConfigurationImpl;
85 bool hasReaderListener()
const;
108 void setReceiverQueueSize(
int size);
113 int getReceiverQueueSize()
const;
120 void setReaderName(
const std::string& readerName);
125 const std::string& getReaderName()
const;
134 void setSubscriptionRolePrefix(
const std::string& subscriptionRolePrefix);
139 const std::string& getSubscriptionRolePrefix()
const;
154 void setReadCompacted(
bool compacted);
159 bool isReadCompacted()
const;
167 void setInternalSubscriptionName(std::string internalSubscriptionName);
172 const std::string& getInternalSubscriptionName()
const;
181 void setUnAckedMessagesTimeoutMs(
const uint64_t milliSeconds);
186 long getUnAckedMessagesTimeoutMs()
const;
200 void setTickDurationInMs(
const uint64_t milliSeconds);
205 long getTickDurationInMs()
const;
215 void setAckGroupingTimeMs(
long ackGroupingMillis);
222 long getAckGroupingTimeMs()
const;
230 void setAckGroupingMaxSize(
long maxGroupingSize);
237 long getAckGroupingMaxSize()
const;
242 bool isEncryptionEnabled()
const;
247 const CryptoKeyReaderPtr getCryptoKeyReader()
const;
259 ConsumerCryptoFailureAction getCryptoFailureAction()
const;
273 bool hasProperty(
const std::string& name)
const;
281 const std::string& getProperty(
const std::string& name)
const;
286 std::map<std::string, std::string>& getProperties()
const;
301 std::shared_ptr<ReaderConfigurationImpl> impl_;