Package org.springframework.pulsar.autoconfigure

Class PulsarReactiveProperties.Reader

java.lang.Object

org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Reader

Enclosing class:

PulsarReactiveProperties

public static class PulsarReactiveProperties.Reader
extends Object

Constructor Summary

Constructors

Constructor	Description
Reader()

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec	buildReactiveMessageReaderSpec()
org.apache.pulsar.client.api.ConsumerCryptoFailureAction	getCryptoFailureAction()
String	getGeneratedSubscriptionNamePrefix()
org.apache.pulsar.client.api.Range[]	getKeyHashRanges()
Boolean	getReadCompacted()
String	getReaderName()
Integer	getReceiverQueueSize()
String	getSubscriptionName()
String[]	getTopicNames()
void	setCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction)
void	setGeneratedSubscriptionNamePrefix(String generatedSubscriptionNamePrefix)
void	setKeyHashRanges(org.apache.pulsar.client.api.Range[] keyHashRanges)
void	setReadCompacted(Boolean readCompacted)
void	setReaderName(String readerName)
void	setReceiverQueueSize(Integer receiverQueueSize)
void	setSubscriptionName(String subscriptionName)
void	setTopicNames(String[] topicNames)

Methods inherited from class java.lang.Object

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

Constructor Details

Reader

public Reader()

Method Details

getTopicNames

public String[] getTopicNames()

setTopicNames

public void setTopicNames(String[] topicNames)

getReaderName

public String getReaderName()

setReaderName

public void setReaderName(String readerName)

getSubscriptionName

public String getSubscriptionName()

setSubscriptionName

public void setSubscriptionName(String subscriptionName)

getGeneratedSubscriptionNamePrefix

public String getGeneratedSubscriptionNamePrefix()

setGeneratedSubscriptionNamePrefix

public void setGeneratedSubscriptionNamePrefix(String generatedSubscriptionNamePrefix)

getReceiverQueueSize

public Integer getReceiverQueueSize()

setReceiverQueueSize

public void setReceiverQueueSize(Integer receiverQueueSize)

getReadCompacted

public Boolean getReadCompacted()

setReadCompacted

public void setReadCompacted(Boolean readCompacted)

getKeyHashRanges

public org.apache.pulsar.client.api.Range[] getKeyHashRanges()

setKeyHashRanges

public void setKeyHashRanges(org.apache.pulsar.client.api.Range[] keyHashRanges)

getCryptoFailureAction

public org.apache.pulsar.client.api.ConsumerCryptoFailureAction getCryptoFailureAction()

setCryptoFailureAction

public void setCryptoFailureAction(org.apache.pulsar.client.api.ConsumerCryptoFailureAction cryptoFailureAction)

buildReactiveMessageReaderSpec

public org.apache.pulsar.reactive.client.api.ReactiveMessageReaderSpec buildReactiveMessageReaderSpec()