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()
      • resendFirstUnconfirmedIdleTimeout

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

        public scala.concurrent.duration.FiniteDuration resendFirsUnconfirmedIdleTimeout()
        Deprecated.
        use resendFirstUnconfirmedIdleTimeout. Since 2.6.19.
      • withResendFirstUnconfirmedIdleTimeout

        public ShardingProducerController.Settings withResendFirstUnconfirmedIdleTimeout​(scala.concurrent.duration.FiniteDuration newResendFirstUnconfirmedIdleTimeout)
      • withResendFirstUnconfirmedIdleTimeout

        public ShardingProducerController.Settings withResendFirstUnconfirmedIdleTimeout​(java.time.Duration newResendFirstUnconfirmedIdleTimeout)
      • withResendFirsUnconfirmedIdleTimeout

        public ShardingProducerController.Settings withResendFirsUnconfirmedIdleTimeout​(scala.concurrent.duration.FiniteDuration newResendFirstUnconfirmedIdleTimeout)
        Deprecated.
        use resendFirstUnconfirmedIdleTimeout. Since 2.6.19.
      • withResendFirsUnconfirmedIdleTimeout

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

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