Package akka.cluster.sharding.typed
Class ShardedDaemonProcessSettings
- java.lang.Object
-
- akka.cluster.sharding.typed.ShardedDaemonProcessSettings
-
public final class ShardedDaemonProcessSettings extends java.lang.Object
Not for user constructions, use factory methods to instantiate.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ShardedDaemonProcessSettings
apply(ActorSystem<?> system)
Scala API: Create default settings for systemstatic ShardedDaemonProcessSettings
create(ActorSystem<?> system)
Java API: Create default settings for systemstatic ShardedDaemonProcessSettings
fromConfig(com.typesafe.config.Config config)
Load settings from a specific config location.int
keepAliveFromNumberOfNodes()
scala.concurrent.duration.FiniteDuration
keepAliveInterval()
scala.concurrent.duration.FiniteDuration
keepAliveThrottleInterval()
scala.Option<java.lang.String>
role()
scala.Option<ClusterShardingSettings>
shardingSettings()
ShardedDaemonProcessSettings
withKeepAliveFromNumberOfNodes(int keepAliveFromNumberOfNodes)
Keep alive messages from this number of nodes.ShardedDaemonProcessSettings
withKeepAliveInterval(java.time.Duration keepAliveInterval)
Java API: The interval each parent of the sharded set is pinged from each node in the cluster.ShardedDaemonProcessSettings
withKeepAliveInterval(scala.concurrent.duration.FiniteDuration keepAliveInterval)
Scala API: The interval each parent of the sharded set is pinged from each node in the cluster.ShardedDaemonProcessSettings
withKeepAliveThrottleInterval(java.time.Duration keepAliveThrottleInterval)
Java API: Keep alive messages are sent with this delay between each message.ShardedDaemonProcessSettings
withKeepAliveThrottleInterval(scala.concurrent.duration.FiniteDuration keepAliveThrottleInterval)
Scala API: Keep alive messages are sent with this delay between each message.ShardedDaemonProcessSettings
withRole(java.lang.String role)
Specifies that the ShardedDaemonProcess should run on nodes with a specific role.ShardedDaemonProcessSettings
withShardingSettings(ClusterShardingSettings shardingSettings)
Specify sharding settings that should be used for the sharded daemon process instead of loading from config.
-
-
-
Method Detail
-
apply
public static ShardedDaemonProcessSettings apply(ActorSystem<?> system)
Scala API: Create default settings for system
-
create
public static ShardedDaemonProcessSettings create(ActorSystem<?> system)
Java API: Create default settings for system
-
fromConfig
public static ShardedDaemonProcessSettings fromConfig(com.typesafe.config.Config config)
Load settings from a specific config location.
-
keepAliveInterval
public scala.concurrent.duration.FiniteDuration keepAliveInterval()
-
shardingSettings
public scala.Option<ClusterShardingSettings> shardingSettings()
-
role
public scala.Option<java.lang.String> role()
-
keepAliveFromNumberOfNodes
public int keepAliveFromNumberOfNodes()
-
keepAliveThrottleInterval
public scala.concurrent.duration.FiniteDuration keepAliveThrottleInterval()
-
withKeepAliveInterval
public ShardedDaemonProcessSettings withKeepAliveInterval(scala.concurrent.duration.FiniteDuration keepAliveInterval)
Scala API: The interval each parent of the sharded set is pinged from each node in the cluster.Note: How the sharded set is kept alive may change in the future meaning this setting may go away.
-
withKeepAliveInterval
public ShardedDaemonProcessSettings withKeepAliveInterval(java.time.Duration keepAliveInterval)
Java API: The interval each parent of the sharded set is pinged from each node in the cluster.Note: How the sharded set is kept alive may change in the future meaning this setting may go away.
-
withShardingSettings
public ShardedDaemonProcessSettings withShardingSettings(ClusterShardingSettings shardingSettings)
Specify sharding settings that should be used for the sharded daemon process instead of loading from config. Some settings can not be changed (remember-entitites and related settings, passivation, number-of-shards), changing those settings will be ignored.
-
withRole
public ShardedDaemonProcessSettings withRole(java.lang.String role)
Specifies that the ShardedDaemonProcess should run on nodes with a specific role. If the role is not specified all nodes in the cluster are used. If the given role does not match the role of the current node the the ShardedDaemonProcess will not be started.
-
withKeepAliveFromNumberOfNodes
public ShardedDaemonProcessSettings withKeepAliveFromNumberOfNodes(int keepAliveFromNumberOfNodes)
Keep alive messages from this number of nodes.
-
withKeepAliveThrottleInterval
public ShardedDaemonProcessSettings withKeepAliveThrottleInterval(scala.concurrent.duration.FiniteDuration keepAliveThrottleInterval)
Scala API: Keep alive messages are sent with this delay between each message.
-
withKeepAliveThrottleInterval
public ShardedDaemonProcessSettings withKeepAliveThrottleInterval(java.time.Duration keepAliveThrottleInterval)
Java API: Keep alive messages are sent with this delay between each message.
-
-