Class PulsarProperties.Consumer
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarProperties.Consumer
- Enclosing class:
- PulsarProperties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.client.api.ConsumerCryptoFailureAction
org.apache.pulsar.client.api.DeadLetterPolicy
org.apache.pulsar.client.api.RegexSubscriptionMode
org.apache.pulsar.client.api.SubscriptionInitialPosition
org.apache.pulsar.client.api.SubscriptionMode
org.apache.pulsar.client.api.SubscriptionType
void
setAcknowledgementsGroupTime
(Duration acknowledgementsGroupTime) void
setAckReceiptEnabled
(Boolean ackReceiptEnabled) void
setAckTimeout
(Duration ackTimeout) void
setAutoAckOldestChunkedMessageOnQueueFull
(Boolean autoAckOldestChunkedMessageOnQueueFull) void
setAutoUpdatePartitions
(Boolean autoUpdatePartitions) void
setAutoUpdatePartitionsInterval
(Duration autoUpdatePartitionsInterval) void
setBatchIndexAckEnabled
(Boolean batchIndexAckEnabled) void
setConsumerName
(String consumerName) void
setCryptoFailureAction
(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction) void
setDeadLetterPolicy
(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) void
setExpireTimeOfIncompleteChunkedMessage
(Duration expireTimeOfIncompleteChunkedMessage) void
setMaxPendingChunkedMessage
(Integer maxPendingChunkedMessage) void
setMaxTotalReceiverQueueSizeAcrossPartitions
(Integer maxTotalReceiverQueueSizeAcrossPartitions) void
setNegativeAckRedeliveryDelay
(Duration negativeAckRedeliveryDelay) void
setPatternAutoDiscoveryPeriod
(Integer patternAutoDiscoveryPeriod) void
setPoolMessages
(Boolean poolMessages) void
setPriorityLevel
(Integer priorityLevel) void
setProperties
(SortedMap<String, String> properties) void
setReadCompacted
(Boolean readCompacted) void
setReceiverQueueSize
(Integer receiverQueueSize) void
setRegexSubscriptionMode
(org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode) void
setReplicateSubscriptionState
(Boolean replicateSubscriptionState) void
setResetIncludeHead
(Boolean resetIncludeHead) void
setRetryEnable
(Boolean retryEnable) void
setStartPaused
(Boolean startPaused) void
setSubscriptionInitialPosition
(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition) void
setSubscriptionMode
(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode) void
setSubscriptionName
(String subscriptionName) void
setSubscriptionProperties
(Map<String, String> subscriptionProperties) void
setSubscriptionType
(org.apache.pulsar.client.api.SubscriptionType subscriptionType) void
setTickDuration
(Duration tickDuration) void
void
setTopicsPattern
(Pattern topicsPattern)
-
Constructor Details
-
Consumer
public Consumer()
-
-
Method Details
-
getTopics
-
setTopics
-
getTopicsPattern
-
setTopicsPattern
-
getSubscriptionName
-
setSubscriptionName
-
getSubscriptionProperties
-
setSubscriptionProperties
-
getSubscriptionMode
public org.apache.pulsar.client.api.SubscriptionMode getSubscriptionMode() -
setSubscriptionMode
public void setSubscriptionMode(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode) -
getSubscriptionType
public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType() -
setSubscriptionType
public void setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) -
getReceiverQueueSize
-
setReceiverQueueSize
-
getAcknowledgementsGroupTime
-
setAcknowledgementsGroupTime
-
getNegativeAckRedeliveryDelay
-
setNegativeAckRedeliveryDelay
-
getMaxTotalReceiverQueueSizeAcrossPartitions
-
setMaxTotalReceiverQueueSizeAcrossPartitions
public void setMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions) -
getConsumerName
-
setConsumerName
-
getAckTimeout
-
setAckTimeout
-
getTickDuration
-
setTickDuration
-
getPriorityLevel
-
setPriorityLevel
-
getCryptoFailureAction
public org.apache.pulsar.client.api.ConsumerCryptoFailureAction getCryptoFailureAction() -
setCryptoFailureAction
public void setCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction) -
getProperties
-
setProperties
-
getReadCompacted
-
setReadCompacted
-
getSubscriptionInitialPosition
public org.apache.pulsar.client.api.SubscriptionInitialPosition getSubscriptionInitialPosition() -
setSubscriptionInitialPosition
public void setSubscriptionInitialPosition(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition) -
getPatternAutoDiscoveryPeriod
-
setPatternAutoDiscoveryPeriod
-
getRegexSubscriptionMode
public org.apache.pulsar.client.api.RegexSubscriptionMode getRegexSubscriptionMode() -
setRegexSubscriptionMode
public void setRegexSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode) -
getDeadLetterPolicy
-
setDeadLetterPolicy
public void setDeadLetterPolicy(@Nullable org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) -
getRetryEnable
-
setRetryEnable
-
getAutoUpdatePartitions
-
setAutoUpdatePartitions
-
getAutoUpdatePartitionsInterval
-
setAutoUpdatePartitionsInterval
-
getReplicateSubscriptionState
-
setReplicateSubscriptionState
-
getResetIncludeHead
-
setResetIncludeHead
-
getBatchIndexAckEnabled
-
setBatchIndexAckEnabled
-
getAckReceiptEnabled
-
setAckReceiptEnabled
-
getPoolMessages
-
setPoolMessages
-
getStartPaused
-
setStartPaused
-
getAutoAckOldestChunkedMessageOnQueueFull
-
setAutoAckOldestChunkedMessageOnQueueFull
public void setAutoAckOldestChunkedMessageOnQueueFull(Boolean autoAckOldestChunkedMessageOnQueueFull) -
getMaxPendingChunkedMessage
-
setMaxPendingChunkedMessage
-
getExpireTimeOfIncompleteChunkedMessage
-
setExpireTimeOfIncompleteChunkedMessage
-
buildProperties
-