Class PulsarContainerProperties
java.lang.Object
org.springframework.pulsar.listener.PulsarContainerProperties
Contains runtime properties for a listener container.
- Author:
- Soby Chacko, Alexander Preuß
-
Constructor Summary
ConstructorsConstructorDescriptionPulsarContainerProperties
(String topicPattern) PulsarContainerProperties
(String... topics) -
Method Summary
Modifier and TypeMethodDescriptionint
int
int
org.apache.pulsar.client.api.Schema<?>
org.apache.pulsar.common.schema.SchemaType
org.apache.pulsar.client.api.SubscriptionType
String[]
boolean
void
setAckMode
(AckMode ackMode) void
setBatchListener
(boolean batchListener) void
setBatchTimeoutMillis
(int batchTimeoutMillis) void
setConsumerStartTimeout
(Duration consumerStartTimeout) Set the timeout to wait for a consumer thread to start before logging an error.void
setConsumerTaskExecutor
(AsyncTaskExecutor consumerExecutor) void
setMaxNumBytes
(int maxNumBytes) void
setMaxNumMessages
(int maxNumMessages) void
setMessageListener
(Object messageListener) void
setObservationConvention
(PulsarListenerObservationConvention observationConvention) Set a custom observation convention.void
setPulsarConsumerProperties
(Properties pulsarConsumerProperties) void
setSchema
(org.apache.pulsar.client.api.Schema<?> schema) void
setSchemaType
(org.apache.pulsar.common.schema.SchemaType schemaType) void
setSubscriptionName
(String subscriptionName) void
setSubscriptionType
(org.apache.pulsar.client.api.SubscriptionType subscriptionType) void
void
setTopicsPattern
(String topicsPattern)
-
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.
-
getSchema
public org.apache.pulsar.client.api.Schema<?> getSchema() -
setSchema
public void setSchema(org.apache.pulsar.client.api.Schema<?> schema) -
getTopics
-
setTopics
-
getTopicsPattern
-
setTopicsPattern
-
getSubscriptionName
-
setSubscriptionName
-
getSchemaType
public org.apache.pulsar.common.schema.SchemaType getSchemaType() -
setSchemaType
public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) -
getPulsarConsumerProperties
-
setPulsarConsumerProperties
-