Class ProducerController.Settings

  • Enclosing class:
    ProducerController

    public static final class ProducerController.Settings
    extends java.lang.Object
    • Constructor Detail

      • Settings

        public Settings()
    • Method Detail

      • durableQueueRequestTimeout

        public scala.concurrent.duration.FiniteDuration durableQueueRequestTimeout()
      • durableQueueRetryAttempts

        public int durableQueueRetryAttempts()
      • durableQueueResendFirstInterval

        public scala.concurrent.duration.FiniteDuration durableQueueResendFirstInterval()
      • chunkLargeMessagesBytes

        public int chunkLargeMessagesBytes()
      • withDurableQueueRetryAttempts

        public ProducerController.Settings withDurableQueueRetryAttempts​(int newDurableQueueRetryAttempts)
      • withDurableQueueRequestTimeout

        public ProducerController.Settings withDurableQueueRequestTimeout​(scala.concurrent.duration.FiniteDuration newDurableQueueRequestTimeout)
        Scala API
      • withDurableQueueResendFirstInterval

        public ProducerController.Settings withDurableQueueResendFirstInterval​(scala.concurrent.duration.FiniteDuration newDurableQueueResendFirstInterval)
        Scala API
      • withDurableQueueRequestTimeout

        public ProducerController.Settings withDurableQueueRequestTimeout​(java.time.Duration newDurableQueueRequestTimeout)
        Java API
      • withDurableQueueResendFirstInterval

        public ProducerController.Settings withDurableQueueResendFirstInterval​(java.time.Duration newDurableQueueResendFirstInterval)
        Java API
      • getDurableQueueRequestTimeout

        public java.time.Duration getDurableQueueRequestTimeout()
        Java API
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object