Class PulsarReactiveProperties.Consumer
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Consumer
- Enclosing class:
- PulsarReactiveProperties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpecorg.apache.pulsar.client.api.ConsumerCryptoFailureActionorg.apache.pulsar.client.api.DeadLetterPolicyorg.apache.pulsar.client.api.SubscriptionInitialPositionorg.apache.pulsar.client.api.SubscriptionModeorg.apache.pulsar.client.api.SubscriptionTypeString[]org.apache.pulsar.client.api.RegexSubscriptionModevoidsetAcknowledgeAsynchronously(Boolean acknowledgeAsynchronously) voidsetAcknowledgementsGroupTime(Duration acknowledgementsGroupTime) voidsetAcknowledgeSchedulerType(PulsarReactiveProperties.SchedulerType acknowledgeSchedulerType) voidsetAckTimeout(Duration ackTimeout) voidsetAckTimeoutTickTime(Duration ackTimeoutTickTime) voidsetAutoAckOldestChunkedMessageOnQueueFull(Boolean autoAckOldestChunkedMessageOnQueueFull) voidsetAutoUpdatePartitions(Boolean autoUpdatePartitions) voidsetAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval) voidsetBatchIndexAckEnabled(Boolean batchIndexAckEnabled) voidsetConsumerName(String consumerName) voidsetCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction) voidsetDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) voidsetExpireTimeOfIncompleteChunkedMessage(Duration expireTimeOfIncompleteChunkedMessage) voidsetMaxPendingChunkedMessage(Integer maxPendingChunkedMessage) voidsetMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions) voidsetNegativeAckRedeliveryDelay(Duration negativeAckRedeliveryDelay) voidsetPriorityLevel(Integer priorityLevel) voidsetProperties(SortedMap<String, String> properties) voidsetReadCompacted(Boolean readCompacted) voidsetReceiverQueueSize(Integer receiverQueueSize) voidsetReplicateSubscriptionState(Boolean replicateSubscriptionState) voidsetRetryLetterTopicEnable(Boolean retryLetterTopicEnable) voidsetSubscriptionInitialPosition(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition) voidsetSubscriptionMode(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode) voidsetSubscriptionName(String subscriptionName) voidsetSubscriptionProperties(SortedMap<String, String> subscriptionProperties) voidsetSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) voidvoidsetTopicsPattern(Pattern topicsPattern) voidsetTopicsPatternAutoDiscoveryPeriod(Duration topicsPatternAutoDiscoveryPeriod) voidsetTopicsPatternSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode topicsPatternSubscriptionMode)
-
Constructor Details
-
Consumer
public Consumer()
-
-
Method Details
-
getTopics
-
setTopics
-
getTopicsPattern
-
setTopicsPattern
-
getSubscriptionName
-
setSubscriptionName
-
getSubscriptionType
public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType() -
setSubscriptionType
public void setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) -
getSubscriptionProperties
-
setSubscriptionProperties
-
getSubscriptionMode
public org.apache.pulsar.client.api.SubscriptionMode getSubscriptionMode() -
setSubscriptionMode
public void setSubscriptionMode(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode) -
getReceiverQueueSize
-
setReceiverQueueSize
-
getAcknowledgementsGroupTime
-
setAcknowledgementsGroupTime
-
getAcknowledgeAsynchronously
-
setAcknowledgeAsynchronously
-
getAcknowledgeSchedulerType
-
setAcknowledgeSchedulerType
public void setAcknowledgeSchedulerType(PulsarReactiveProperties.SchedulerType acknowledgeSchedulerType) -
getNegativeAckRedeliveryDelay
-
setNegativeAckRedeliveryDelay
-
getDeadLetterPolicy
public org.apache.pulsar.client.api.DeadLetterPolicy getDeadLetterPolicy() -
setDeadLetterPolicy
public void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) -
getRetryLetterTopicEnable
-
setRetryLetterTopicEnable
-
getMaxTotalReceiverQueueSizeAcrossPartitions
-
setMaxTotalReceiverQueueSizeAcrossPartitions
public void setMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions) -
getConsumerName
-
setConsumerName
-
getAckTimeout
-
setAckTimeout
-
getAckTimeoutTickTime
-
setAckTimeoutTickTime
-
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
-
getBatchIndexAckEnabled
-
setBatchIndexAckEnabled
-
getSubscriptionInitialPosition
public org.apache.pulsar.client.api.SubscriptionInitialPosition getSubscriptionInitialPosition() -
setSubscriptionInitialPosition
public void setSubscriptionInitialPosition(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition) -
getTopicsPatternAutoDiscoveryPeriod
-
setTopicsPatternAutoDiscoveryPeriod
-
getTopicsPatternSubscriptionMode
public org.apache.pulsar.client.api.RegexSubscriptionMode getTopicsPatternSubscriptionMode() -
setTopicsPatternSubscriptionMode
public void setTopicsPatternSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode topicsPatternSubscriptionMode) -
getAutoUpdatePartitions
-
setAutoUpdatePartitions
-
getAutoUpdatePartitionsInterval
-
setAutoUpdatePartitionsInterval
-
getReplicateSubscriptionState
-
setReplicateSubscriptionState
-
getAutoAckOldestChunkedMessageOnQueueFull
-
setAutoAckOldestChunkedMessageOnQueueFull
public void setAutoAckOldestChunkedMessageOnQueueFull(Boolean autoAckOldestChunkedMessageOnQueueFull) -
getMaxPendingChunkedMessage
-
setMaxPendingChunkedMessage
-
getExpireTimeOfIncompleteChunkedMessage
-
setExpireTimeOfIncompleteChunkedMessage
-
buildReactiveMessageConsumerSpec
public org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec buildReactiveMessageConsumerSpec()
-