Package org.apache.pekko.actor.typed.delivery

Class ConsumerController.Settings

java.lang.Object

org.apache.pekko.actor.typed.delivery.ConsumerController.Settings

Enclosing class:

ConsumerController

public static final class ConsumerController.Settings
extends Object

Constructor Summary

Constructors

Constructor	Description
Settings()

Method Summary

Modifier and Type	Method	Description
int	flowControlWindow()
Duration	getResendIntervalMax()	Java API
boolean	onlyFlowControl()
scala.concurrent.duration.FiniteDuration	resendIntervalMax()
scala.concurrent.duration.FiniteDuration	resendIntervalMin()
String	toString()
ConsumerController.Settings	withFlowControlWindow(int newFlowControlWindow)
ConsumerController.Settings	withOnlyFlowControl(boolean newOnlyFlowControl)
ConsumerController.Settings	withResendIntervalMax(Duration newResendIntervalMax)	Java API
ConsumerController.Settings	withResendIntervalMax(scala.concurrent.duration.FiniteDuration newResendIntervalMax)	Scala API
ConsumerController.Settings	withResendIntervalMin(Duration newResendIntervalMin)	Java API
ConsumerController.Settings	withResendIntervalMin(scala.concurrent.duration.FiniteDuration newResendIntervalMin)	Scala API

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

Settings

public Settings()

Method Details

flowControlWindow

public int flowControlWindow()

resendIntervalMin

public scala.concurrent.duration.FiniteDuration resendIntervalMin()

resendIntervalMax

public scala.concurrent.duration.FiniteDuration resendIntervalMax()

onlyFlowControl

public boolean onlyFlowControl()

withFlowControlWindow

public ConsumerController.Settings withFlowControlWindow(int newFlowControlWindow)

withResendIntervalMin

public ConsumerController.Settings withResendIntervalMin(scala.concurrent.duration.FiniteDuration newResendIntervalMin)

Scala API

withResendIntervalMax

public ConsumerController.Settings withResendIntervalMax(scala.concurrent.duration.FiniteDuration newResendIntervalMax)

Scala API

withResendIntervalMin

public ConsumerController.Settings withResendIntervalMin(Duration newResendIntervalMin)

Java API

withResendIntervalMax

public ConsumerController.Settings withResendIntervalMax(Duration newResendIntervalMax)

Java API

getResendIntervalMax

public Duration getResendIntervalMax()

Java API

withOnlyFlowControl

public ConsumerController.Settings withOnlyFlowControl(boolean newOnlyFlowControl)

toString

public String toString()

Overrides:

toString in class Object