Class PulsarProperties.Consumer

java.lang.Object

org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

Enclosing class:

PulsarProperties

public static class PulsarProperties.Consumer
extends Object

Since:

4.0.0

Author:

Chris Bono, Phillip Webb, Swamy Mavuri, Vedran Pavic

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PulsarProperties.Consumer.DeadLetterPolicy
static class	PulsarProperties.Consumer.Subscription

Constructor Summary

Constructors

Constructor	Description
Consumer()

Method Summary

Modifier and Type	Method	Description
@Nullable PulsarProperties.Consumer.DeadLetterPolicy	getDeadLetterPolicy()
@Nullable String	getName()
int	getPriorityLevel()
PulsarProperties.Consumer.Subscription	getSubscription()
@Nullable List<String>	getTopics()
@Nullable Pattern	getTopicsPattern()
boolean	isReadCompacted()
boolean	isRetryEnable()
void	setDeadLetterPolicy(@Nullable PulsarProperties.Consumer.DeadLetterPolicy deadLetterPolicy)
void	setName(@Nullable String name)
void	setPriorityLevel(int priorityLevel)
void	setReadCompacted(boolean readCompacted)
void	setRetryEnable(boolean retryEnable)
void	setTopics(@Nullable List<String> topics)
void	setTopicsPattern(@Nullable Pattern topicsPattern)

Methods inherited from class Object

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

Constructor Details

Consumer

public Consumer()

Method Details

getName

public @Nullable String getName()

setName

public void setName(@Nullable String name)

getSubscription

public PulsarProperties.Consumer.Subscription getSubscription()

getTopics

public @Nullable List<String> getTopics()

setTopics

public void setTopics(@Nullable List<String> topics)

getTopicsPattern

public @Nullable Pattern getTopicsPattern()

setTopicsPattern

public void setTopicsPattern(@Nullable Pattern topicsPattern)

getPriorityLevel

public int getPriorityLevel()

setPriorityLevel

public void setPriorityLevel(int priorityLevel)

isReadCompacted

public boolean isReadCompacted()

setReadCompacted

public void setReadCompacted(boolean readCompacted)

getDeadLetterPolicy

public @Nullable PulsarProperties.Consumer.DeadLetterPolicy getDeadLetterPolicy()

setDeadLetterPolicy

public void setDeadLetterPolicy(@Nullable PulsarProperties.Consumer.DeadLetterPolicy deadLetterPolicy)

isRetryEnable

public boolean isRetryEnable()

setRetryEnable

public void setRetryEnable(boolean retryEnable)