Class ShardingProducerController.Settings

  • Enclosing class:
    ShardingProducerController

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

      • Settings

        public Settings()
    • Method Detail

      • bufferSize

        public int bufferSize()
      • internalAskTimeout

        public scala.concurrent.duration.FiniteDuration internalAskTimeout()
      • cleanupUnusedAfter

        public scala.concurrent.duration.FiniteDuration cleanupUnusedAfter()
      • resendFirsUnconfirmedIdleTimeout

        public scala.concurrent.duration.FiniteDuration resendFirsUnconfirmedIdleTimeout()
      • withResendFirsUnconfirmedIdleTimeout

        public ShardingProducerController.Settings withResendFirsUnconfirmedIdleTimeout​(scala.concurrent.duration.FiniteDuration newResendFirsUnconfirmedIdleTimeout)
      • withResendFirsUnconfirmedIdleTimeout

        public ShardingProducerController.Settings withResendFirsUnconfirmedIdleTimeout​(java.time.Duration newResendFirsUnconfirmedIdleTimeout)
      • toString

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