Class PulsarContainerProperties
java.lang.Object
org.springframework.pulsar.listener.PulsarContainerProperties
Contains runtime properties for a listener container.
- Author:
- Soby Chacko, Alexander Preuß, Chris Bono
-
Constructor Summary
ConstructorsConstructorDescriptionPulsarContainerProperties(String topicPattern) PulsarContainerProperties(String... topics) -
Method Summary
Modifier and TypeMethodDescriptionintintintorg.apache.pulsar.client.api.Schema<?>org.apache.pulsar.common.schema.SchemaTypeorg.apache.pulsar.client.api.SubscriptionTypebooleanvoidsetAckMode(AckMode ackMode) voidsetBatchListener(boolean batchListener) voidsetBatchTimeoutMillis(int batchTimeoutMillis) voidsetConsumerStartTimeout(Duration consumerStartTimeout) Set the timeout to wait for a consumer thread to start before logging an error.voidsetConsumerTaskExecutor(AsyncTaskExecutor consumerExecutor) voidsetMaxNumBytes(int maxNumBytes) voidsetMaxNumMessages(int maxNumMessages) voidsetMessageListener(Object messageListener) voidsetObservationConvention(PulsarListenerObservationConvention observationConvention) Set a custom observation convention.voidsetPulsarConsumerProperties(Properties pulsarConsumerProperties) voidsetSchema(org.apache.pulsar.client.api.Schema<?> schema) voidsetSchemaResolver(SchemaResolver schemaResolver) voidsetSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) voidsetSubscriptionName(String subscriptionName) voidsetSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) voidsetTopicResolver(TopicResolver topicResolver) voidvoidsetTopicsPattern(String topicsPattern) void
-
Constructor Details
-
PulsarContainerProperties
-
PulsarContainerProperties
-
-
Method Details
-
getMessageListener
-
setMessageListener
-
getConsumerTaskExecutor
-
setConsumerTaskExecutor
-
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
-
setAckMode
-
getObservationConvention
-
setObservationConvention
Set a custom observation convention.- Parameters:
observationConvention- the convention.
-
getConsumerStartTimeout
-
setConsumerStartTimeout
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
-
setTopics
-
getTopicsPattern
-
setTopicsPattern
-
getSubscriptionName
-
setSubscriptionName
-
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
-
setSchemaResolver
-
getTopicResolver
-
setTopicResolver
-
getPulsarConsumerProperties
-
setPulsarConsumerProperties
-
updateContainerProperties
public void updateContainerProperties()
-