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ß

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

    • getObservationConvention

      public PulsarListenerObservationConvention getObservationConvention()

    • setObservationConvention

      public void setObservationConvention(PulsarListenerObservationConvention observationConvention)
      Set a custom observation convention.
      Parameters:
      observationConvention - the convention.

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

    • getSchema

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

    • setSchema

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

    • getTopics

      public String[] getTopics()

    • setTopics

      public void setTopics(String[] topics)

    • getTopicsPattern

      public String getTopicsPattern()

    • setTopicsPattern

      public void setTopicsPattern(String topicsPattern)

    • getSubscriptionName

      public String getSubscriptionName()

    • setSubscriptionName

      public void setSubscriptionName(String subscriptionName)

    • getSchemaType

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

    • setSchemaType

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

    • getPulsarConsumerProperties

      public Properties getPulsarConsumerProperties()

    • setPulsarConsumerProperties

      public void setPulsarConsumerProperties(Properties pulsarConsumerProperties)