Package org.springframework.pulsar.autoconfigure

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 Classes

Modifier and Type	Class	Description
static class	PulsarReactiveProperties.Cache
static class	PulsarReactiveProperties.Consumer
static class	PulsarReactiveProperties.Listener
static class	PulsarReactiveProperties.Reader
static enum	PulsarReactiveProperties.SchedulerType
static class	PulsarReactiveProperties.Sender

Constructor Summary

Constructors

Constructor	Description
PulsarReactiveProperties()

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerSpec	buildReactiveMessageConsumerSpec()
org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec	buildReactiveMessageReaderSpec()
org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec	buildReactiveMessageSenderSpec()
PulsarReactiveProperties.Consumer	getConsumer()
PulsarReactiveProperties.Listener	getListener()
PulsarReactiveProperties.Reader	getReader()
PulsarReactiveProperties.Sender	getSender()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PulsarReactiveProperties

public PulsarReactiveProperties()

Method Details

getSender

public PulsarReactiveProperties.Sender getSender()

getConsumer

public PulsarReactiveProperties.Consumer getConsumer()

getReader

public PulsarReactiveProperties.Reader getReader()

getListener

public PulsarReactiveProperties.Listener 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()