Class PulsarReactiveProperties.Listener
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Listener
- Enclosing class:
- PulsarReactiveProperties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.common.schema.SchemaType
void
setHandlingTimeout
(Duration handlingTimeout) void
setSchemaType
(org.apache.pulsar.common.schema.SchemaType schemaType) void
setUseKeyOrderedProcessing
(Boolean useKeyOrderedProcessing)
-
Constructor Details
-
Listener
public Listener()
-
-
Method Details
-
getSchemaType
public org.apache.pulsar.common.schema.SchemaType getSchemaType() -
setSchemaType
public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType) -
getHandlingTimeout
-
setHandlingTimeout
-
getUseKeyOrderedProcessing
-
setUseKeyOrderedProcessing
-