Class PulsarReactiveProperties
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarReactiveProperties
@ConfigurationProperties(prefix="spring.pulsar.reactive")
public class PulsarReactiveProperties
extends Object
Configuration properties for Spring for the Apache Pulsar reactive client.
Users should refer to Pulsar reactive client documentation for complete descriptions of these properties.
- Author:
- Christophe Bornet
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
static class
static class
static class
static enum
static class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec
org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec
org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec
-
Constructor Details
-
PulsarReactiveProperties
public PulsarReactiveProperties()
-
-
Method Details
-
getSender
-
getConsumer
-
getReader
-
getListener
-
buildReactiveMessageSenderSpec
public org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec buildReactiveMessageSenderSpec() -
buildReactiveMessageReaderSpec
public org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec buildReactiveMessageReaderSpec() -
buildReactiveMessageConsumerSpec
public org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec buildReactiveMessageConsumerSpec()
-