Class PulsarProperties.Producer

java.lang.Object

org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

Enclosing class:

PulsarProperties

public static class PulsarProperties.Producer
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.Producer.Cache

Constructor Summary

Constructors

Constructor	Description
Producer()

Method Summary

Modifier and Type	Method	Description
ProducerAccessMode	getAccessMode()
PulsarProperties.Producer.Cache	getCache()
@Nullable CompressionType	getCompressionType()
HashingScheme	getHashingScheme()
MessageRoutingMode	getMessageRoutingMode()
@Nullable String	getName()
Duration	getSendTimeout()
@Nullable String	getTopicName()
boolean	isBatchingEnabled()
boolean	isChunkingEnabled()
void	setAccessMode(ProducerAccessMode accessMode)
void	setBatchingEnabled(boolean batchingEnabled)
void	setChunkingEnabled(boolean chunkingEnabled)
void	setCompressionType(@Nullable CompressionType compressionType)
void	setHashingScheme(HashingScheme hashingScheme)
void	setMessageRoutingMode(MessageRoutingMode messageRoutingMode)
void	setName(@Nullable String name)
void	setSendTimeout(Duration sendTimeout)
void	setTopicName(@Nullable String topicName)

Methods inherited from class Object

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

Constructor Details

Producer

public Producer()

Method Details

getName

public @Nullable String getName()

setName

public void setName(@Nullable String name)

getTopicName

public @Nullable String getTopicName()

setTopicName

public void setTopicName(@Nullable String topicName)

getSendTimeout

public Duration getSendTimeout()

setSendTimeout

public void setSendTimeout(Duration sendTimeout)

getMessageRoutingMode

public MessageRoutingMode getMessageRoutingMode()

setMessageRoutingMode

public void setMessageRoutingMode(MessageRoutingMode messageRoutingMode)

getHashingScheme

public HashingScheme getHashingScheme()

setHashingScheme

public void setHashingScheme(HashingScheme hashingScheme)

isBatchingEnabled

public boolean isBatchingEnabled()

setBatchingEnabled

public void setBatchingEnabled(boolean batchingEnabled)

isChunkingEnabled

public boolean isChunkingEnabled()

setChunkingEnabled

public void setChunkingEnabled(boolean chunkingEnabled)

getCompressionType

public @Nullable CompressionType getCompressionType()

setCompressionType

public void setCompressionType(@Nullable CompressionType compressionType)

getAccessMode

public ProducerAccessMode getAccessMode()

setAccessMode

public void setAccessMode(ProducerAccessMode accessMode)

getCache

public PulsarProperties.Producer.Cache getCache()