Package org.springframework.pulsar.autoconfigure

Class PulsarReactiveProperties.Sender

java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Sender
Enclosing class:
PulsarReactiveProperties
public static class PulsarReactiveProperties.Sender extends Object

  • Constructor Details

    • Sender

      public Sender()

  • Method Details

    • getTopicName

      public String getTopicName()

    • setTopicName

      public void setTopicName(String topicName)

    • getProducerName

      public String getProducerName()

    • setProducerName

      public void setProducerName(String producerName)

    • getSendTimeout

      public Duration getSendTimeout()

    • setSendTimeout

      public void setSendTimeout(Duration sendTimeout)

    • getMaxPendingMessages

      public Integer getMaxPendingMessages()

    • setMaxPendingMessages

      public void setMaxPendingMessages(Integer maxPendingMessages)

    • getMaxPendingMessagesAcrossPartitions

      public Integer getMaxPendingMessagesAcrossPartitions()

    • setMaxPendingMessagesAcrossPartitions

      public void setMaxPendingMessagesAcrossPartitions(Integer maxPendingMessagesAcrossPartitions)

    • 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

      public Duration getBatchingMaxPublishDelay()

    • setBatchingMaxPublishDelay

      public void setBatchingMaxPublishDelay(Duration batchingMaxPublishDelay)

    • getRoundRobinRouterBatchingPartitionSwitchFrequency

      public Integer getRoundRobinRouterBatchingPartitionSwitchFrequency()

    • setRoundRobinRouterBatchingPartitionSwitchFrequency

      public void setRoundRobinRouterBatchingPartitionSwitchFrequency(Integer roundRobinRouterBatchingPartitionSwitchFrequency)

    • getBatchingMaxMessages

      public Integer getBatchingMaxMessages()

    • setBatchingMaxMessages

      public void setBatchingMaxMessages(Integer batchingMaxMessages)

    • getBatchingMaxBytes

      public DataSize getBatchingMaxBytes()

    • setBatchingMaxBytes

      public void setBatchingMaxBytes(DataSize batchingMaxBytes)

    • getBatchingEnabled

      public Boolean getBatchingEnabled()

    • setBatchingEnabled

      public void setBatchingEnabled(Boolean batchingEnabled)

    • getChunkingEnabled

      public Boolean getChunkingEnabled()

    • setChunkingEnabled

      public void setChunkingEnabled(Boolean chunkingEnabled)

    • getEncryptionKeys

      public Set<String> getEncryptionKeys()

    • setEncryptionKeys

      public void setEncryptionKeys(Set<String> encryptionKeys)

    • getCompressionType

      public org.apache.pulsar.client.api.CompressionType getCompressionType()

    • setCompressionType

      public void setCompressionType(org.apache.pulsar.client.api.CompressionType compressionType)

    • getInitialSequenceId

      @Nullable public Long getInitialSequenceId()

    • setInitialSequenceId

      public void setInitialSequenceId(@Nullable Long initialSequenceId)

    • getAutoUpdatePartitions

      public Boolean getAutoUpdatePartitions()

    • setAutoUpdatePartitions

      public void setAutoUpdatePartitions(Boolean autoUpdatePartitions)

    • getAutoUpdatePartitionsInterval

      public Duration getAutoUpdatePartitionsInterval()

    • setAutoUpdatePartitionsInterval

      public void setAutoUpdatePartitionsInterval(Duration autoUpdatePartitionsInterval)

    • getMultiSchema

      public Boolean getMultiSchema()

    • setMultiSchema

      public void setMultiSchema(Boolean multiSchema)

    • getProducerAccessMode

      public org.apache.pulsar.client.api.ProducerAccessMode getProducerAccessMode()

    • setProducerAccessMode

      public void setProducerAccessMode(org.apache.pulsar.client.api.ProducerAccessMode producerAccessMode)

    • getLazyStartPartitionedProducers

      public Boolean getLazyStartPartitionedProducers()

    • setLazyStartPartitionedProducers

      public void setLazyStartPartitionedProducers(Boolean lazyStartPartitionedProducers)

    • getProperties

      public Map<String,String> getProperties()

    • setProperties

      public void setProperties(Map<String,String> properties)

    • getCache

      public PulsarReactiveProperties.Cache getCache()

    • buildReactiveMessageSenderSpec

      public org.apache.pulsar.reactive.client.api.ReactiveMessageSenderSpec buildReactiveMessageSenderSpec()