Package akka.actor.typed.delivery
Class ProducerController.Settings
- java.lang.Object
-
- akka.actor.typed.delivery.ProducerController.Settings
-
- Enclosing class:
- ProducerController
public static final class ProducerController.Settings extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description Settings()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intchunkLargeMessagesBytes()scala.concurrent.duration.FiniteDurationdurableQueueRequestTimeout()scala.concurrent.duration.FiniteDurationdurableQueueResendFirstInterval()intdurableQueueRetryAttempts()java.time.DurationgetDurableQueueRequestTimeout()Java APIjava.lang.StringtoString()ProducerController.SettingswithChunkLargeMessagesBytes(int newChunkLargeMessagesBytes)ProducerController.SettingswithDurableQueueRequestTimeout(java.time.Duration newDurableQueueRequestTimeout)Java APIProducerController.SettingswithDurableQueueRequestTimeout(scala.concurrent.duration.FiniteDuration newDurableQueueRequestTimeout)Scala APIProducerController.SettingswithDurableQueueResendFirstInterval(java.time.Duration newDurableQueueResendFirstInterval)Java APIProducerController.SettingswithDurableQueueResendFirstInterval(scala.concurrent.duration.FiniteDuration newDurableQueueResendFirstInterval)Scala APIProducerController.SettingswithDurableQueueRetryAttempts(int newDurableQueueRetryAttempts)
-
-
-
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
-
withChunkLargeMessagesBytes
public ProducerController.Settings withChunkLargeMessagesBytes(int newChunkLargeMessagesBytes)
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-