Package org.apache.pekko.actor.typed.delivery

Class ProducerController.Settings

java.lang.Object
org.apache.pekko.actor.typed.delivery.ProducerController.Settings
Enclosing class:
ProducerController
public static final class ProducerController.Settings extends Object

  • Constructor Details

    • Settings

      public Settings()

  • Method Details

    • 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(Duration newDurableQueueRequestTimeout)
      Java API

    • withDurableQueueResendFirstInterval

      public ProducerController.Settings withDurableQueueResendFirstInterval(Duration newDurableQueueResendFirstInterval)
      Java API

    • getDurableQueueRequestTimeout

      public Duration getDurableQueueRequestTimeout()
      Java API

    • withChunkLargeMessagesBytes

      public ProducerController.Settings withChunkLargeMessagesBytes(int newChunkLargeMessagesBytes)

    • toString

      public String toString()
      Overrides:
      toString in class Object