Package org.springframework.pulsar.autoconfigure

Class PulsarReactiveProperties.Consumer

java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Consumer
Enclosing class:
PulsarReactiveProperties
public static class PulsarReactiveProperties.Consumer extends Object

  • Constructor Details

    • Consumer

      public Consumer()

  • Method Details

    • getTopics

      public String[] getTopics()

    • setTopics

      public void setTopics(String[] topics)

    • getTopicsPattern

      public Pattern getTopicsPattern()

    • setTopicsPattern

      public void setTopicsPattern(Pattern topicsPattern)

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)

    • getSubscriptionType

      public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType()

    • setSubscriptionType

      public void setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType)

    • getSubscriptionProperties

      public SortedMap<String,String> getSubscriptionProperties()

    • setSubscriptionProperties

      public void setSubscriptionProperties(SortedMap<String,String> subscriptionProperties)

    • getSubscriptionMode

      public org.apache.pulsar.client.api.SubscriptionMode getSubscriptionMode()

    • setSubscriptionMode

      public void setSubscriptionMode(org.apache.pulsar.client.api.SubscriptionMode subscriptionMode)

    • getReceiverQueueSize

      public Integer getReceiverQueueSize()

    • setReceiverQueueSize

      public void setReceiverQueueSize(Integer receiverQueueSize)

    • getAcknowledgementsGroupTime

      public Duration getAcknowledgementsGroupTime()

    • setAcknowledgementsGroupTime

      public void setAcknowledgementsGroupTime(Duration acknowledgementsGroupTime)

    • getAcknowledgeAsynchronously

      public Boolean getAcknowledgeAsynchronously()

    • setAcknowledgeAsynchronously

      public void setAcknowledgeAsynchronously(Boolean acknowledgeAsynchronously)

    • getAcknowledgeSchedulerType

      public PulsarReactiveProperties.SchedulerType getAcknowledgeSchedulerType()

    • setAcknowledgeSchedulerType

      public void setAcknowledgeSchedulerType(PulsarReactiveProperties.SchedulerType acknowledgeSchedulerType)

    • getNegativeAckRedeliveryDelay

      public Duration getNegativeAckRedeliveryDelay()

    • setNegativeAckRedeliveryDelay

      public void setNegativeAckRedeliveryDelay(Duration negativeAckRedeliveryDelay)

    • getDeadLetterPolicy

      public org.apache.pulsar.client.api.DeadLetterPolicy getDeadLetterPolicy()

    • setDeadLetterPolicy

      public void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy)

    • getRetryLetterTopicEnable

      public Boolean getRetryLetterTopicEnable()

    • setRetryLetterTopicEnable

      public void setRetryLetterTopicEnable(Boolean retryLetterTopicEnable)

    • getMaxTotalReceiverQueueSizeAcrossPartitions

      public Integer getMaxTotalReceiverQueueSizeAcrossPartitions()

    • setMaxTotalReceiverQueueSizeAcrossPartitions

      public void setMaxTotalReceiverQueueSizeAcrossPartitions(Integer maxTotalReceiverQueueSizeAcrossPartitions)

    • getConsumerName

      public String getConsumerName()

    • setConsumerName

      public void setConsumerName(String consumerName)

    • getAckTimeout

      public Duration getAckTimeout()

    • setAckTimeout

      public void setAckTimeout(Duration ackTimeout)

    • getAckTimeoutTickTime

      public Duration getAckTimeoutTickTime()

    • setAckTimeoutTickTime

      public void setAckTimeoutTickTime(Duration ackTimeoutTickTime)

    • getPriorityLevel

      public Integer getPriorityLevel()

    • setPriorityLevel

      public void setPriorityLevel(Integer priorityLevel)

    • getCryptoFailureAction

      public org.apache.pulsar.client.api.ConsumerCryptoFailureAction getCryptoFailureAction()

    • setCryptoFailureAction

      public void setCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction)

    • getProperties

      public SortedMap<String,String> getProperties()

    • setProperties

      public void setProperties(SortedMap<String,String> properties)

    • getReadCompacted

      public Boolean getReadCompacted()

    • setReadCompacted

      public void setReadCompacted(Boolean readCompacted)

    • getBatchIndexAckEnabled

      public Boolean getBatchIndexAckEnabled()

    • setBatchIndexAckEnabled

      public void setBatchIndexAckEnabled(Boolean batchIndexAckEnabled)

    • getSubscriptionInitialPosition

      public org.apache.pulsar.client.api.SubscriptionInitialPosition getSubscriptionInitialPosition()

    • setSubscriptionInitialPosition

      public void setSubscriptionInitialPosition(org.apache.pulsar.client.api.SubscriptionInitialPosition subscriptionInitialPosition)

    • getTopicsPatternAutoDiscoveryPeriod

      public Duration getTopicsPatternAutoDiscoveryPeriod()

    • setTopicsPatternAutoDiscoveryPeriod

      public void setTopicsPatternAutoDiscoveryPeriod(Duration topicsPatternAutoDiscoveryPeriod)

    • getTopicsPatternSubscriptionMode

      public org.apache.pulsar.client.api.RegexSubscriptionMode getTopicsPatternSubscriptionMode()

    • setTopicsPatternSubscriptionMode

      public void setTopicsPatternSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode topicsPatternSubscriptionMode)

    • getAutoUpdatePartitions

      public Boolean getAutoUpdatePartitions()

    • setAutoUpdatePartitions

      public void setAutoUpdatePartitions(Boolean autoUpdatePartitions)

    • getAutoUpdatePartitionsInterval

      public Duration getAutoUpdatePartitionsInterval()

    • setAutoUpdatePartitionsInterval

      public void setAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval)

    • getReplicateSubscriptionState

      public Boolean getReplicateSubscriptionState()

    • setReplicateSubscriptionState

      public void setReplicateSubscriptionState(Boolean replicateSubscriptionState)

    • getAutoAckOldestChunkedMessageOnQueueFull

      public Boolean getAutoAckOldestChunkedMessageOnQueueFull()

    • setAutoAckOldestChunkedMessageOnQueueFull

      public void setAutoAckOldestChunkedMessageOnQueueFull(Boolean autoAckOldestChunkedMessageOnQueueFull)

    • getMaxPendingChunkedMessage

      public Integer getMaxPendingChunkedMessage()

    • setMaxPendingChunkedMessage

      public void setMaxPendingChunkedMessage(Integer maxPendingChunkedMessage)

    • getExpireTimeOfIncompleteChunkedMessage

      public Duration getExpireTimeOfIncompleteChunkedMessage()

    • setExpireTimeOfIncompleteChunkedMessage

      public void setExpireTimeOfIncompleteChunkedMessage(Duration expireTimeOfIncompleteChunkedMessage)

    • buildReactiveMessageConsumerSpec

      public org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec buildReactiveMessageConsumerSpec()