Class PulsarReactiveProperties.Sender
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Sender
- Enclosing class:
- PulsarReactiveProperties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec
getCache()
org.apache.pulsar.client.api.CompressionType
org.apache.pulsar.client.api.ProducerCryptoFailureAction
org.apache.pulsar.client.api.HashingScheme
org.apache.pulsar.client.api.MessageRoutingMode
org.apache.pulsar.client.api.ProducerAccessMode
void
setAutoUpdatePartitions
(Boolean autoUpdatePartitions) void
setAutoUpdatePartitionsInterval
(Duration autoUpdatePartitionsInterval) void
setBatchingEnabled
(Boolean batchingEnabled) void
setBatchingMaxBytes
(DataSize batchingMaxBytes) void
setBatchingMaxMessages
(Integer batchingMaxMessages) void
setBatchingMaxPublishDelay
(Duration batchingMaxPublishDelay) void
setChunkingEnabled
(Boolean chunkingEnabled) void
setCompressionType
(org.apache.pulsar.client.api.CompressionType compressionType) void
setCryptoFailureAction
(org.apache.pulsar.client.api.ProducerCryptoFailureAction cryptoFailureAction) void
setEncryptionKeys
(Set<String> encryptionKeys) void
setHashingScheme
(org.apache.pulsar.client.api.HashingScheme hashingScheme) void
setInitialSequenceId
(Long initialSequenceId) void
setLazyStartPartitionedProducers
(Boolean lazyStartPartitionedProducers) void
setMaxPendingMessages
(Integer maxPendingMessages) void
setMaxPendingMessagesAcrossPartitions
(Integer maxPendingMessagesAcrossPartitions) void
setMessageRoutingMode
(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) void
setMultiSchema
(Boolean multiSchema) void
setProducerAccessMode
(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode) void
setProducerName
(String producerName) void
setProperties
(Map<String, String> properties) void
setRoundRobinRouterBatchingPartitionSwitchFrequency
(Integer roundRobinRouterBatchingPartitionSwitchFrequency) void
setSendTimeout
(Duration sendTimeout) void
setTopicName
(String topicName)
-
Constructor Details
-
Sender
public Sender()
-
-
Method Details
-
getTopicName
-
setTopicName
-
getProducerName
-
setProducerName
-
getSendTimeout
-
setSendTimeout
-
getMaxPendingMessages
-
setMaxPendingMessages
-
getMaxPendingMessagesAcrossPartitions
-
setMaxPendingMessagesAcrossPartitions
-
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) -
getCryptoFailureAction
public org.apache.pulsar.client.api.ProducerCryptoFailureAction getCryptoFailureAction() -
setCryptoFailureAction
public void setCryptoFailureAction(org.apache.pulsar.client.api.ProducerCryptoFailureAction cryptoFailureAction) -
getBatchingMaxPublishDelay
-
setBatchingMaxPublishDelay
-
getRoundRobinRouterBatchingPartitionSwitchFrequency
-
setRoundRobinRouterBatchingPartitionSwitchFrequency
public void setRoundRobinRouterBatchingPartitionSwitchFrequency(Integer roundRobinRouterBatchingPartitionSwitchFrequency) -
getBatchingMaxMessages
-
setBatchingMaxMessages
-
getBatchingMaxBytes
-
setBatchingMaxBytes
-
getBatchingEnabled
-
setBatchingEnabled
-
getChunkingEnabled
-
setChunkingEnabled
-
getEncryptionKeys
-
setEncryptionKeys
-
getCompressionType
public org.apache.pulsar.client.api.CompressionType getCompressionType() -
setCompressionType
public void setCompressionType(org.apache.pulsar.client.api.CompressionType compressionType) -
getInitialSequenceId
-
setInitialSequenceId
-
getAutoUpdatePartitions
-
setAutoUpdatePartitions
-
getAutoUpdatePartitionsInterval
-
setAutoUpdatePartitionsInterval
-
getMultiSchema
-
setMultiSchema
-
getProducerAccessMode
public org.apache.pulsar.client.api.ProducerAccessMode getProducerAccessMode() -
setProducerAccessMode
public void setProducerAccessMode(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode) -
getLazyStartPartitionedProducers
-
setLazyStartPartitionedProducers
-
getProperties
-
setProperties
-
getCache
-
buildReactiveMessageSenderSpec
public org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec buildReactiveMessageSenderSpec()
-