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.ReactiveMessageSenderSpecgetCache()org.apache.pulsar.client.api.CompressionTypeorg.apache.pulsar.client.api.ProducerCryptoFailureActionorg.apache.pulsar.client.api.HashingSchemeorg.apache.pulsar.client.api.MessageRoutingModeorg.apache.pulsar.client.api.ProducerAccessModevoidsetAutoUpdatePartitions(Boolean autoUpdatePartitions) voidsetAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval) voidsetBatchingEnabled(Boolean batchingEnabled) voidsetBatchingMaxBytes(DataSize batchingMaxBytes) voidsetBatchingMaxMessages(Integer batchingMaxMessages) voidsetBatchingMaxPublishDelay(Duration batchingMaxPublishDelay) voidsetChunkingEnabled(Boolean chunkingEnabled) voidsetCompressionType(org.apache.pulsar.client.api.CompressionType compressionType) voidsetCryptoFailureAction(org.apache.pulsar.client.api.ProducerCryptoFailureAction cryptoFailureAction) voidsetEncryptionKeys(Set<String> encryptionKeys) voidsetHashingScheme(org.apache.pulsar.client.api.HashingScheme hashingScheme) voidsetInitialSequenceId(Long initialSequenceId) voidsetLazyStartPartitionedProducers(Boolean lazyStartPartitionedProducers) voidsetMaxPendingMessages(Integer maxPendingMessages) voidsetMaxPendingMessagesAcrossPartitions(Integer maxPendingMessagesAcrossPartitions) voidsetMessageRoutingMode(org.apache.pulsar.client.api.MessageRoutingMode messageRoutingMode) voidsetMultiSchema(Boolean multiSchema) voidsetProducerAccessMode(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode) voidsetProducerName(String producerName) voidsetProperties(Map<String, String> properties) voidsetRoundRobinRouterBatchingPartitionSwitchFrequency(Integer roundRobinRouterBatchingPartitionSwitchFrequency) voidsetSendTimeout(Duration sendTimeout) voidsetTopicName(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()
-