Class ReactivePulsarContainerProperties<T>
java.lang.Object
org.springframework.pulsar.reactive.listener.ReactivePulsarContainerProperties<T>
- Type Parameters:
T- message type.
Contains runtime properties for a reactive listener container.
- Author:
- Christophe Bornet
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintorg.apache.pulsar.client.api.Schema<T>org.apache.pulsar.common.schema.SchemaTypeorg.apache.pulsar.client.api.SubscriptionTypebooleanvoidsetConcurrency(int concurrency) voidsetHandlingTimeout(Duration handlingTimeout) voidsetMessageHandler(ReactivePulsarMessageHandler messageHandler) voidvoidsetSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) voidsetSubscriptionName(String subscriptionName) voidsetSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) voidsetTopics(Collection<String> topics) voidsetTopicsPattern(String topicsPattern) voidsetTopicsPattern(Pattern topicsPattern) voidsetUseKeyOrderedProcessing(boolean useKeyOrderedProcessing)
-
Constructor Details
-
ReactivePulsarContainerProperties
public ReactivePulsarContainerProperties()
-
-
Method Details
-
getMessageHandler
-
setMessageHandler
-
getSubscriptionType
public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType() -
setSubscriptionType
public void setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType) -
getSchema
-
setSchema
-
getSchemaType
public org.apache.pulsar.common.schema.SchemaType getSchemaType() -
setSchemaType
public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) -
getTopics
-
setTopics
-
getTopicsPattern
-
setTopicsPattern
-
setTopicsPattern
-
getSubscriptionName
-
setSubscriptionName
-
getHandlingTimeout
-
setHandlingTimeout
-
getConcurrency
public int getConcurrency() -
setConcurrency
public void setConcurrency(int concurrency) -
isUseKeyOrderedProcessing
public boolean isUseKeyOrderedProcessing() -
setUseKeyOrderedProcessing
public void setUseKeyOrderedProcessing(boolean useKeyOrderedProcessing)
-