Package org.springframework.pulsar.reactive.listener

Class ReactivePulsarContainerProperties<T>

java.lang.Object
org.springframework.pulsar.reactive.listener.ReactivePulsarContainerProperties<T>
Type Parameters:
T - message type.
public class ReactivePulsarContainerProperties<T> extends Object
Contains runtime properties for a reactive listener container.
Author:
Christophe Bornet

  • Constructor Details

    • ReactivePulsarContainerProperties

      public ReactivePulsarContainerProperties()

  • Method Details

    • getMessageHandler

      public ReactivePulsarMessageHandler getMessageHandler()

    • setMessageHandler

      public void setMessageHandler(ReactivePulsarMessageHandler messageHandler)

    • getSubscriptionType

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

    • setSubscriptionType

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

    • getSchema

      public org.apache.pulsar.client.api.Schema<T> getSchema()

    • setSchema

      public void setSchema(org.apache.pulsar.client.api.Schema<T> schema)

    • getSchemaType

      public org.apache.pulsar.common.schema.SchemaType getSchemaType()

    • setSchemaType

      public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)

    • getSchemaResolver

      public SchemaResolver getSchemaResolver()

    • setSchemaResolver

      public void setSchemaResolver(SchemaResolver schemaResolver)

    • getTopicResolver

      public TopicResolver getTopicResolver()

    • setTopicResolver

      public void setTopicResolver(TopicResolver topicResolver)

    • getTopics

      public Collection<String> getTopics()

    • setTopics

      public void setTopics(Collection<String> topics)

    • getTopicsPattern

      public Pattern getTopicsPattern()

    • setTopicsPattern

      public void setTopicsPattern(Pattern topicsPattern)

    • setTopicsPattern

      public void setTopicsPattern(String topicsPattern)

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)

    • getHandlingTimeout

      public Duration getHandlingTimeout()

    • setHandlingTimeout

      public void setHandlingTimeout(Duration handlingTimeout)

    • getConcurrency

      public int getConcurrency()

    • setConcurrency

      public void setConcurrency(int concurrency)

    • isUseKeyOrderedProcessing

      public boolean isUseKeyOrderedProcessing()

    • setUseKeyOrderedProcessing

      public void setUseKeyOrderedProcessing(boolean useKeyOrderedProcessing)