クラス PulsarProperties.Producer
java.lang.ObjectSE
org.springframework.boot.autoconfigure.pulsar.PulsarProperties.Producer
- 含まれているクラス:
- PulsarProperties
ネストされたクラスの要約
ネストされたクラスコンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.ProducerAccessModegetCache()org.apache.pulsar.client.api.CompressionTypeorg.apache.pulsar.client.api.HashingSchemeorg.apache.pulsar.client.api.MessageRoutingModegetName()booleanbooleanvoidsetAccessMode(org.apache.pulsar.client.api.ProducerAccessMode accessMode) voidsetBatchingEnabled(boolean batchingEnabled) voidsetChunkingEnabled(boolean chunkingEnabled) voidsetCompressionType(org.apache.pulsar.client.api.CompressionType compressionType) voidsetHashingScheme(org.apache.pulsar.client.api.HashingScheme hashingScheme) voidsetMessageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) voidvoidsetSendTimeout(DurationSE sendTimeout) voidsetTopicName(StringSE topicName)
コンストラクターの詳細
Producer
public Producer()
メソッドの詳細
getName
setName
getTopicName
setTopicName
getSendTimeout
setSendTimeout
getMessageRoutingMode
public org.apache.pulsar.client.api.MessageRoutingMode getMessageRoutingMode()setMessageRoutingMode
public void setMessageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) getHashingScheme
public org.apache.pulsar.client.api.HashingScheme getHashingScheme()setHashingScheme
public void setHashingScheme(org.apache.pulsar.client.api.HashingScheme hashingScheme) isBatchingEnabled
public boolean isBatchingEnabled()setBatchingEnabled
public void setBatchingEnabled(boolean batchingEnabled) isChunkingEnabled
public boolean isChunkingEnabled()setChunkingEnabled
public void setChunkingEnabled(boolean chunkingEnabled) getCompressionType
public org.apache.pulsar.client.api.CompressionType getCompressionType()setCompressionType
public void setCompressionType(org.apache.pulsar.client.api.CompressionType compressionType) getAccessMode
public org.apache.pulsar.client.api.ProducerAccessMode getAccessMode()setAccessMode
public void setAccessMode(org.apache.pulsar.client.api.ProducerAccessMode accessMode) getCache