クラス PulsarProperties.Producer
java.lang.ObjectSE
org.springframework.boot.autoconfigure.pulsar.PulsarProperties.Producer
- 含まれているクラス:
- PulsarProperties
ネストされたクラスのサマリー
ネストされたクラスコンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.ProducerAccessMode
getCache()
org.apache.pulsar.client.api.CompressionType
org.apache.pulsar.client.api.HashingScheme
org.apache.pulsar.client.api.MessageRoutingMode
getName()
boolean
boolean
void
setAccessMode
(org.apache.pulsar.client.api.ProducerAccessMode accessMode) void
setBatchingEnabled
(boolean batchingEnabled) void
setChunkingEnabled
(boolean chunkingEnabled) void
setCompressionType
(org.apache.pulsar.client.api.CompressionType compressionType) void
setHashingScheme
(org.apache.pulsar.client.api.HashingScheme hashingScheme) void
setMessageRoutingMode
(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) void
void
setSendTimeout
(DurationSE sendTimeout) void
setTopicName
(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