Package org.springframework.pulsar.listener

Class PulsarContainerProperties

java.lang.Object
org.springframework.pulsar.listener.PulsarContainerProperties
public class PulsarContainerProperties extends Object
Contains runtime properties for a listener container.
Author:
Soby Chacko, Alexander Preuß, Chris Bono

  • Constructor Details

    • PulsarContainerProperties

      public PulsarContainerProperties(String... topics)

    • PulsarContainerProperties

      public PulsarContainerProperties(String topicPattern)

  • Method Details

    • getMessageListener

      public Object getMessageListener()

    • setMessageListener

      public void setMessageListener(Object messageListener)

    • getConsumerTaskExecutor

      public AsyncTaskExecutor getConsumerTaskExecutor()

    • setConsumerTaskExecutor

      public void setConsumerTaskExecutor(AsyncTaskExecutor consumerExecutor)

    • getSubscriptionType

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

    • setSubscriptionType

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

    • getMaxNumMessages

      public int getMaxNumMessages()

    • setMaxNumMessages

      public void setMaxNumMessages(int maxNumMessages)

    • getMaxNumBytes

      public int getMaxNumBytes()

    • setMaxNumBytes

      public void setMaxNumBytes(int maxNumBytes)

    • getBatchTimeoutMillis

      public int getBatchTimeoutMillis()

    • setBatchTimeoutMillis

      public void setBatchTimeoutMillis(int batchTimeoutMillis)

    • isBatchListener

      public boolean isBatchListener()

    • setBatchListener

      public void setBatchListener(boolean batchListener)

    • getAckMode

      public AckMode getAckMode()

    • setAckMode

      public void setAckMode(AckMode ackMode)

    • isObservationEnabled

      public boolean isObservationEnabled()

    • setObservationEnabled

      public void setObservationEnabled(boolean observationEnabled)

    • getObservationRegistry

      public io.micrometer.observation.ObservationRegistry getObservationRegistry()

    • getObservationConvention

      public PulsarListenerObservationConvention getObservationConvention()

    • getConsumerStartTimeout

      public Duration getConsumerStartTimeout()

    • setConsumerStartTimeout

      public void setConsumerStartTimeout(Duration consumerStartTimeout)
      Set the timeout to wait for a consumer thread to start before logging an error. Default 30 seconds.
      Parameters:
      consumerStartTimeout - the consumer start timeout.

    • getTopics

      public Set<String> getTopics()

    • setTopics

      public void setTopics(Set<String> topics)

    • getTopicsPattern

      public String getTopicsPattern()

    • setTopicsPattern

      public void setTopicsPattern(String topicsPattern)

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)

    • getSchema

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

    • setSchema

      public void setSchema(org.apache.pulsar.client.api.Schema<?> 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)

    • getPulsarConsumerProperties

      public Properties getPulsarConsumerProperties()

    • setPulsarConsumerProperties

      public void setPulsarConsumerProperties(Properties pulsarConsumerProperties)

    • transactions

      public PulsarContainerProperties.TransactionSettings transactions()
      Gets the transaction settings.
      Returns:
      the transaction settings
      Since:
      1.1.0

    • updateContainerProperties

      public void updateContainerProperties()