Package akka.actor.typed.delivery
Class WorkPullingProducerController.Settings
- java.lang.Object
-
- akka.actor.typed.delivery.WorkPullingProducerController.Settings
-
- Enclosing class:
- WorkPullingProducerController
public static final class WorkPullingProducerController.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
bufferSize()
scala.concurrent.duration.FiniteDuration
internalAskTimeout()
ProducerController.Settings
producerControllerSettings()
java.lang.String
toString()
WorkPullingProducerController.Settings
withBufferSize(int newBufferSize)
WorkPullingProducerController.Settings
withInternalAskTimeout(java.time.Duration newInternalAskTimeout)
WorkPullingProducerController.Settings
withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout)
WorkPullingProducerController.Settings
withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)
-
-
-
Method Detail
-
bufferSize
public int bufferSize()
-
internalAskTimeout
public scala.concurrent.duration.FiniteDuration internalAskTimeout()
-
producerControllerSettings
public ProducerController.Settings producerControllerSettings()
-
withBufferSize
public WorkPullingProducerController.Settings withBufferSize(int newBufferSize)
-
withInternalAskTimeout
public WorkPullingProducerController.Settings withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout)
-
withInternalAskTimeout
public WorkPullingProducerController.Settings withInternalAskTimeout(java.time.Duration newInternalAskTimeout)
-
withProducerControllerSettings
public WorkPullingProducerController.Settings withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-