Class PulsarProperties.Consumer

java.lang.Object
org.springframework.boot.autoconfigure.pulsar.PulsarProperties.Consumer
Enclosing class:
PulsarProperties

public static class PulsarProperties.Consumer extends Object
  • Constructor Details

    • Consumer

      public Consumer()
  • Method Details

    • getName

      public String getName()
    • setName

      public void setName(String name)
    • getSubscription

      public PulsarProperties.Consumer.Subscription getSubscription()
    • getTopics

      public List<String> getTopics()
    • setTopics

      public void setTopics(List<String> topics)
    • getTopicsPattern

      public Pattern getTopicsPattern()
    • setTopicsPattern

      public void setTopicsPattern(Pattern topicsPattern)
    • getPriorityLevel

      public int getPriorityLevel()
    • setPriorityLevel

      public void setPriorityLevel(int priorityLevel)
    • isReadCompacted

      public boolean isReadCompacted()
    • setReadCompacted

      public void setReadCompacted(boolean readCompacted)
    • getDeadLetterPolicy

      public PulsarProperties.Consumer.DeadLetterPolicy getDeadLetterPolicy()
    • setDeadLetterPolicy

      public void setDeadLetterPolicy(PulsarProperties.Consumer.DeadLetterPolicy deadLetterPolicy)
    • isRetryEnable

      public boolean isRetryEnable()
    • setRetryEnable

      public void setRetryEnable(boolean retryEnable)