Class WorkPullingProducerController.Settings
java.lang.Object
org.apache.pekko.actor.typed.delivery.WorkPullingProducerController.Settings
- Enclosing class:
- WorkPullingProducerController
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintscala.concurrent.duration.FiniteDurationtoString()withBufferSize(int newBufferSize) withInternalAskTimeout(Duration newInternalAskTimeout) withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout) withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)
-
Constructor Details
-
Settings
public Settings()
-
-
Method Details
-
bufferSize
public int bufferSize() -
internalAskTimeout
public scala.concurrent.duration.FiniteDuration internalAskTimeout() -
producerControllerSettings
-
withBufferSize
-
withInternalAskTimeout
public WorkPullingProducerController.Settings withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout) -
withInternalAskTimeout
public WorkPullingProducerController.Settings withInternalAskTimeout(Duration newInternalAskTimeout) -
withProducerControllerSettings
public WorkPullingProducerController.Settings withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings) -
toString
-