pulsar-client-cpp
Loading...
Searching...
No Matches
pulsar::ConsumerConfiguration Member List

This is the complete list of members for pulsar::ConsumerConfiguration, including all inherited members.

clone() constpulsar::ConsumerConfiguration
ConsumerConfiguration() (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfiguration
ConsumerConfiguration(const ConsumerConfiguration &) (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfiguration
getAckGroupingMaxSize() constpulsar::ConsumerConfiguration
getAckGroupingTimeMs() constpulsar::ConsumerConfiguration
getBatchReceivePolicy() constpulsar::ConsumerConfiguration
getBrokerConsumerStatsCacheTimeInMs() constpulsar::ConsumerConfiguration
getConsumerEventListener() constpulsar::ConsumerConfiguration
getConsumerName() constpulsar::ConsumerConfiguration
getConsumerType() constpulsar::ConsumerConfiguration
getCryptoFailureAction() constpulsar::ConsumerConfiguration
getCryptoKeyReader() constpulsar::ConsumerConfiguration
getDeadLetterPolicy() constpulsar::ConsumerConfiguration
getExpireTimeOfIncompleteChunkedMessageMs() constpulsar::ConsumerConfiguration
getInterceptors() const (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfiguration
getKeySharedPolicy() constpulsar::ConsumerConfiguration
getMaxPendingChunkedMessage() constpulsar::ConsumerConfiguration
getMaxTotalReceiverQueueSizeAcrossPartitions() constpulsar::ConsumerConfiguration
getMessageListener() constpulsar::ConsumerConfiguration
getNegativeAckRedeliveryDelayMs() constpulsar::ConsumerConfiguration
getPatternAutoDiscoveryPeriod() constpulsar::ConsumerConfiguration
getPriorityLevel() constpulsar::ConsumerConfiguration
getProperties() constpulsar::ConsumerConfiguration
getProperty(const std::string &name) constpulsar::ConsumerConfiguration
getReceiverQueueSize() constpulsar::ConsumerConfiguration
getRegexSubscriptionMode() constpulsar::ConsumerConfiguration
getSchema() constpulsar::ConsumerConfiguration
getSubscriptionInitialPosition() constpulsar::ConsumerConfiguration
getSubscriptionProperties() constpulsar::ConsumerConfiguration
getTickDurationInMs() constpulsar::ConsumerConfiguration
getUnAckedMessagesTimeoutMs() constpulsar::ConsumerConfiguration
hasConsumerEventListener() constpulsar::ConsumerConfiguration
hasMessageListener() constpulsar::ConsumerConfiguration
hasProperty(const std::string &name) constpulsar::ConsumerConfiguration
intercept(const std::vector< ConsumerInterceptorPtr > &interceptors)pulsar::ConsumerConfiguration
isAckReceiptEnabled() constpulsar::ConsumerConfiguration
isAutoAckOldestChunkedMessageOnQueueFull() constpulsar::ConsumerConfiguration
isBatchIndexAckEnabled() constpulsar::ConsumerConfiguration
isEncryptionEnabled() constpulsar::ConsumerConfiguration
isReadCompacted() constpulsar::ConsumerConfiguration
isReplicateSubscriptionStateEnabled() constpulsar::ConsumerConfiguration
isStartMessageIdInclusive() constpulsar::ConsumerConfiguration
operator=(const ConsumerConfiguration &) (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfiguration
PulsarFriend (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfigurationfriend
PulsarWrapper (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfigurationfriend
setAckGroupingMaxSize(long maxGroupingSize)pulsar::ConsumerConfiguration
setAckGroupingTimeMs(long ackGroupingMillis)pulsar::ConsumerConfiguration
setAckReceiptEnabled(bool ackReceiptEnabled)pulsar::ConsumerConfiguration
setAutoAckOldestChunkedMessageOnQueueFull(bool autoAckOldestChunkedMessageOnQueueFull)pulsar::ConsumerConfiguration
setBatchIndexAckEnabled(bool enabled)pulsar::ConsumerConfiguration
setBatchReceivePolicy(const BatchReceivePolicy &batchReceivePolicy)pulsar::ConsumerConfiguration
setBrokerConsumerStatsCacheTimeInMs(const long cacheTimeInMs)pulsar::ConsumerConfiguration
setConsumerEventListener(ConsumerEventListenerPtr eventListener)pulsar::ConsumerConfiguration
setConsumerName(const std::string &consumerName)pulsar::ConsumerConfiguration
setConsumerType(ConsumerType consumerType)pulsar::ConsumerConfiguration
setCryptoFailureAction(ConsumerCryptoFailureAction action)pulsar::ConsumerConfiguration
setCryptoKeyReader(CryptoKeyReaderPtr cryptoKeyReader)pulsar::ConsumerConfiguration
setDeadLetterPolicy(const DeadLetterPolicy &deadLetterPolicy)pulsar::ConsumerConfiguration
setExpireTimeOfIncompleteChunkedMessageMs(long expireTimeOfIncompleteChunkedMessageMs)pulsar::ConsumerConfiguration
setKeySharedPolicy(KeySharedPolicy keySharedPolicy)pulsar::ConsumerConfiguration
setMaxPendingChunkedMessage(size_t maxPendingChunkedMessage)pulsar::ConsumerConfiguration
setMaxTotalReceiverQueueSizeAcrossPartitions(int maxTotalReceiverQueueSizeAcrossPartitions)pulsar::ConsumerConfiguration
setMessageListener(MessageListener messageListener)pulsar::ConsumerConfiguration
setNegativeAckRedeliveryDelayMs(long redeliveryDelayMillis)pulsar::ConsumerConfiguration
setPatternAutoDiscoveryPeriod(int periodInSeconds)pulsar::ConsumerConfiguration
setPriorityLevel(int priorityLevel)pulsar::ConsumerConfiguration
setProperties(const std::map< std::string, std::string > &properties)pulsar::ConsumerConfiguration
setProperty(const std::string &name, const std::string &value)pulsar::ConsumerConfiguration
setReadCompacted(bool compacted)pulsar::ConsumerConfiguration
setReceiverQueueSize(int size)pulsar::ConsumerConfiguration
setRegexSubscriptionMode(RegexSubscriptionMode regexSubscriptionMode)pulsar::ConsumerConfiguration
setReplicateSubscriptionStateEnabled(bool enabled)pulsar::ConsumerConfiguration
setSchema(const SchemaInfo &schemaInfo)pulsar::ConsumerConfiguration
setStartMessageIdInclusive(bool startMessageIdInclusive)pulsar::ConsumerConfiguration
setSubscriptionInitialPosition(InitialPosition subscriptionInitialPosition)pulsar::ConsumerConfiguration
setSubscriptionProperties(const std::map< std::string, std::string > &subscriptionProperties)pulsar::ConsumerConfiguration
setTickDurationInMs(const uint64_t milliSeconds)pulsar::ConsumerConfiguration
setTypedMessageListener(std::function< void(Consumer &, const TypedMessage< T > &)> listener, typename TypedMessage< T >::Decoder decoder) (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfigurationinline
setUnAckedMessagesTimeoutMs(const uint64_t milliSeconds)pulsar::ConsumerConfiguration
~ConsumerConfiguration() (defined in pulsar::ConsumerConfiguration)pulsar::ConsumerConfiguration
Generated by doxygen 1.9.8