Package akka.cluster.sharding.typed.delivery

Class ShardingProducerController.Settings

java.lang.Object

akka.cluster.sharding.typed.delivery.ShardingProducerController.Settings

Enclosing class:

ShardingProducerController

public static final class ShardingProducerController.Settings
extends java.lang.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()
scala.concurrent.duration.FiniteDuration	resendFirsUnconfirmedIdleTimeout()	Deprecated. use resendFirstUnconfirmedIdleTimeout.
java.lang.String	toString()
ShardingProducerController.Settings	withBufferSize(int newBufferSize)
ShardingProducerController.Settings	withCleanupUnusedAfter(java.time.Duration newCleanupUnusedAfter)
ShardingProducerController.Settings	withCleanupUnusedAfter(scala.concurrent.duration.FiniteDuration newCleanupUnusedAfter)
ShardingProducerController.Settings	withInternalAskTimeout(java.time.Duration newInternalAskTimeout)
ShardingProducerController.Settings	withInternalAskTimeout(scala.concurrent.duration.FiniteDuration newInternalAskTimeout)
ShardingProducerController.Settings	withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)
ShardingProducerController.Settings	withResendFirstUnconfirmedIdleTimeout(java.time.Duration newResendFirstUnconfirmedIdleTimeout)
ShardingProducerController.Settings	withResendFirstUnconfirmedIdleTimeout(scala.concurrent.duration.FiniteDuration newResendFirstUnconfirmedIdleTimeout)
ShardingProducerController.Settings	withResendFirsUnconfirmedIdleTimeout(java.time.Duration newResendFirstUnconfirmedIdleTimeout)	Deprecated.
ShardingProducerController.Settings	withResendFirsUnconfirmedIdleTimeout(scala.concurrent.duration.FiniteDuration newResendFirstUnconfirmedIdleTimeout)	Deprecated. use resendFirstUnconfirmedIdleTimeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

Settings

public Settings()

Method Detail

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()

resendFirsUnconfirmedIdleTimeout

public scala.concurrent.duration.FiniteDuration resendFirsUnconfirmedIdleTimeout()

Deprecated.

use resendFirstUnconfirmedIdleTimeout. Since 2.6.19.

withBufferSize

public ShardingProducerController.Settings withBufferSize(int newBufferSize)

withInternalAskTimeout

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

withInternalAskTimeout

public ShardingProducerController.Settings withInternalAskTimeout(java.time.Duration newInternalAskTimeout)

withCleanupUnusedAfter

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

withCleanupUnusedAfter

public ShardingProducerController.Settings withCleanupUnusedAfter(java.time.Duration newCleanupUnusedAfter)

withResendFirstUnconfirmedIdleTimeout

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

withResendFirstUnconfirmedIdleTimeout

public ShardingProducerController.Settings withResendFirstUnconfirmedIdleTimeout(java.time.Duration newResendFirstUnconfirmedIdleTimeout)

withResendFirsUnconfirmedIdleTimeout

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

Deprecated.

use resendFirstUnconfirmedIdleTimeout. Since 2.6.19.

withResendFirsUnconfirmedIdleTimeout

public ShardingProducerController.Settings withResendFirsUnconfirmedIdleTimeout(java.time.Duration newResendFirstUnconfirmedIdleTimeout)

Deprecated.

withProducerControllerSettings

public ShardingProducerController.Settings withProducerControllerSettings(ProducerController.Settings newProducerControllerSettings)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object