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 TypeMethodDescriptionint
org.apache.pulsar.client.api.Schema<T>
org.apache.pulsar.common.schema.SchemaType
org.apache.pulsar.client.api.SubscriptionType
boolean
void
setConcurrency
(int concurrency) void
setHandlingTimeout
(Duration handlingTimeout) void
setMessageHandler
(ReactivePulsarMessageHandler messageHandler) void
void
setSchemaType
(org.apache.pulsar.common.schema.SchemaType schemaType) void
setSubscriptionName
(String subscriptionName) void
setSubscriptionType
(org.apache.pulsar.client.api.SubscriptionType subscriptionType) void
setTopics
(Collection<String> topics) void
setTopicsPattern
(String topicsPattern) void
setTopicsPattern
(Pattern topicsPattern) void
setUseKeyOrderedProcessing
(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)
-