Package org.springframework.pulsar.autoconfigure

Class PulsarProperties.Consumer

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

  • Constructor Details

    • Consumer

      public Consumer()

  • Method Details

    • getTopics

      public Set<String> getTopics()

    • setTopics

      public void setTopics(Set<String> topics)

    • getTopicsPattern

      public Pattern getTopicsPattern()

    • setTopicsPattern

      public void setTopicsPattern(Pattern topicsPattern)

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)

    • getSubscriptionProperties

      public Map<String,String> getSubscriptionProperties()

    • setSubscriptionProperties

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

    • 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

      public Integer getReceiverQueueSize()

    • setReceiverQueueSize

      public void setReceiverQueueSize(Integer receiverQueueSize)

    • getAcknowledgementsGroupTime

      public Duration getAcknowledgementsGroupTime()

    • setAcknowledgementsGroupTime

      public void setAcknowledgementsGroupTime(Duration acknowledgementsGroupTime)

    • getNegativeAckRedeliveryDelay

      public Duration getNegativeAckRedeliveryDelay()

    • setNegativeAckRedeliveryDelay

      public void setNegativeAckRedeliveryDelay(Duration negativeAckRedeliveryDelay)

    • 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)

    • getTickDuration

      public Duration getTickDuration()

    • setTickDuration

      public void setTickDuration(Duration tickDuration)

    • 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)

    • getSubscriptionInitialPosition

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

    • setSubscriptionInitialPosition

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

    • getPatternAutoDiscoveryPeriod

      public Integer getPatternAutoDiscoveryPeriod()

    • setPatternAutoDiscoveryPeriod

      public void setPatternAutoDiscoveryPeriod(Integer patternAutoDiscoveryPeriod)

    • getRegexSubscriptionMode

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

    • setRegexSubscriptionMode

      public void setRegexSubscriptionMode(org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode)

    • getDeadLetterPolicy

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

    • setDeadLetterPolicy

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

    • getRetryEnable

      public Boolean getRetryEnable()

    • setRetryEnable

      public void setRetryEnable(Boolean retryEnable)

    • 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)

    • getResetIncludeHead

      public Boolean getResetIncludeHead()

    • setResetIncludeHead

      public void setResetIncludeHead(Boolean resetIncludeHead)

    • getBatchIndexAckEnabled

      public Boolean getBatchIndexAckEnabled()

    • setBatchIndexAckEnabled

      public void setBatchIndexAckEnabled(Boolean batchIndexAckEnabled)

    • getAckReceiptEnabled

      public Boolean getAckReceiptEnabled()

    • setAckReceiptEnabled

      public void setAckReceiptEnabled(Boolean ackReceiptEnabled)

    • getPoolMessages

      public Boolean getPoolMessages()

    • setPoolMessages

      public void setPoolMessages(Boolean poolMessages)

    • getStartPaused

      public Boolean getStartPaused()

    • setStartPaused

      public void setStartPaused(Boolean startPaused)

    • 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)

    • buildProperties

      public Map<String,Object> buildProperties()