Class PulsarProperties.Reader

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

public static class PulsarProperties.Reader extends Object
  • Constructor Details

    • Reader

      public Reader()
  • Method Details

    • getTopicNames

      public List<String> getTopicNames()
    • setTopicNames

      public void setTopicNames(List<String> topicNames)
    • getReceiverQueueSize

      public Integer getReceiverQueueSize()
    • setReceiverQueueSize

      public void setReceiverQueueSize(Integer receiverQueueSize)
    • getReaderName

      public String getReaderName()
    • setReaderName

      public void setReaderName(String readerName)
    • getSubscriptionName

      public String getSubscriptionName()
    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)
    • getSubscriptionRolePrefix

      public String getSubscriptionRolePrefix()
    • setSubscriptionRolePrefix

      public void setSubscriptionRolePrefix(String subscriptionRolePrefix)
    • getReadCompacted

      public Boolean getReadCompacted()
    • setReadCompacted

      public void setReadCompacted(Boolean readCompacted)
    • getResetIncludeHead

      public Boolean getResetIncludeHead()
    • setResetIncludeHead

      public void setResetIncludeHead(Boolean resetIncludeHead)
    • toReaderBuilderCustomizer

      public ReaderBuilderCustomizer<?> toReaderBuilderCustomizer()