Package org.apache.pekko.cluster.sharding.typed.delivery

Class ShardingProducerController.Settings

java.lang.Object

org.apache.pekko.cluster.sharding.typed.delivery.ShardingProducerController.Settings

Enclosing class:

ShardingProducerController

public static final class ShardingProducerController.Settings
extends Object

Constructor Summary

Constructors

Constructor	Description
Settings()

Method Summary

Modifier and Type	Method	Description
int	bufferSize()
scala.concurrent.duration.FiniteDuration	cleanupUnusedAfter()
scala.concurrent.duration.FiniteDuration	internalAskTimeout()
ProducerController.Settings	producerControllerSettings()
scala.concurrent.duration.FiniteDuration	resendFirstUnconfirmedIdleTimeout()
String	toString()
ShardingProducerController.Settings	withBufferSize(int newBufferSize)
ShardingProducerController.Settings	withCleanupUnusedAfter(Duration newCleanupUnusedAfter)
ShardingProducerController.Settings	withCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter)
ShardingProducerController.Settings	withInternalAskTimeout(Duration newInternalAskTimeout)
ShardingProducerController.Settings	withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout)
ShardingProducerController.Settings	withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)
ShardingProducerController.Settings	withResendFirstUnconfirmedIdleTimeout(Duration newResendFirstUnconfirmedIdleTimeout)
ShardingProducerController.Settings	withResendFirstUnconfirmedIdleTimeout(scala.concurrent.duration.FiniteDuration newResendFirstUnconfirmedIdleTimeout)

Methods inherited from class java.lang.Object

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

Constructor Details

Settings

public Settings()

Method Details

bufferSize

public int bufferSize()

internalAskTimeout

public scala.concurrent.duration.FiniteDuration internalAskTimeout()

cleanupUnusedAfter

public scala.concurrent.duration.FiniteDuration cleanupUnusedAfter()

resendFirstUnconfirmedIdleTimeout

public scala.concurrent.duration.FiniteDuration resendFirstUnconfirmedIdleTimeout()

producerControllerSettings

public ProducerController.Settings producerControllerSettings()

withBufferSize

public ShardingProducerController.Settings withBufferSize(int newBufferSize)

withInternalAskTimeout

public ShardingProducerController.Settings withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout)

withInternalAskTimeout

public ShardingProducerController.Settings withInternalAskTimeout(Duration newInternalAskTimeout)

withCleanupUnusedAfter

public ShardingProducerController.Settings withCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter)

withCleanupUnusedAfter

public ShardingProducerController.Settings withCleanupUnusedAfter(Duration newCleanupUnusedAfter)

withResendFirstUnconfirmedIdleTimeout

public ShardingProducerController.Settings withResendFirstUnconfirmedIdleTimeout(scala.concurrent.duration.FiniteDuration newResendFirstUnconfirmedIdleTimeout)

withResendFirstUnconfirmedIdleTimeout

public ShardingProducerController.Settings withResendFirstUnconfirmedIdleTimeout(Duration newResendFirstUnconfirmedIdleTimeout)

withProducerControllerSettings

public ShardingProducerController.Settings withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)

toString

public String toString()

Overrides:

toString in class Object