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 int
chunkLargeMessagesBytes()
scala.concurrent.duration.FiniteDuration
durableQueueRequestTimeout()
scala.concurrent.duration.FiniteDuration
durableQueueResendFirstInterval()
int
durableQueueRetryAttempts()
java.time.Duration
getDurableQueueRequestTimeout()
Java APIjava.lang.String
toString()
ProducerController.Settings
withChunkLargeMessagesBytes(int newChunkLargeMessagesBytes)
ProducerController.Settings
withDurableQueueRequestTimeout(java.time.Duration newDurableQueueRequestTimeout)
Java APIProducerController.Settings
withDurableQueueRequestTimeout(scala.concurrent.duration.FiniteDuration newDurableQueueRequestTimeout)
Scala APIProducerController.Settings
withDurableQueueResendFirstInterval(java.time.Duration newDurableQueueResendFirstInterval)
Java APIProducerController.Settings
withDurableQueueResendFirstInterval(scala.concurrent.duration.FiniteDuration newDurableQueueResendFirstInterval)
Scala APIProducerController.Settings
withDurableQueueRetryAttempts(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:
toString
in classjava.lang.Object
-
-