Class WorkPullingProducerController.Settings
- java.lang.Object
-
- org.apache.pekko.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 intbufferSize()scala.concurrent.duration.FiniteDurationinternalAskTimeout()ProducerController.SettingsproducerControllerSettings()java.lang.StringtoString()WorkPullingProducerController.SettingswithBufferSize(int newBufferSize)WorkPullingProducerController.SettingswithInternalAskTimeout(java.time.Duration newInternalAskTimeout)WorkPullingProducerController.SettingswithInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout)WorkPullingProducerController.SettingswithProducerControllerSettings(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:
toStringin classjava.lang.Object
-
-