diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/ShardedDaemonProcess.cs b/src/contrib/cluster/Akka.Cluster.Sharding/ShardedDaemonProcess.cs index 2be1f5d25b7..855e9f09518 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/ShardedDaemonProcess.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/ShardedDaemonProcess.cs @@ -43,9 +43,10 @@ protected override void PreStart() { base.PreStart(); - Context.System.Log.Debug("Starting Sharded Daemon Process KeepAlivePinger for [{0}], with ping interval [{1}]"); - Timers.StartPeriodicTimer("tick", Tick.Instance, Settings.KeepAliveInterval); TriggerStartAll(); + Context.System.Log.Debug("Starting Sharded Daemon Process KeepAlivePinger for [{0}], with ping interval [{1}]", + Name, Settings.KeepAliveInterval); + Timers.StartPeriodicTimer("tick", Tick.Instance, Settings.KeepAliveInterval); } protected override void OnReceive(object message) @@ -175,7 +176,8 @@ public void Init(string name, int numberOfInstances, Func propsFacto TimeSpan.Zero, // passivation disabled StateStoreMode.DData, shardingBaseSettings.TuningParameters, - shardingBaseSettings.CoordinatorSingletonSettings); + shardingBaseSettings.CoordinatorSingletonSettings, + shardingBaseSettings.LeaseSettings); if (string.IsNullOrEmpty(shardingSettings.Role) || Cluster.Get(_system).SelfRoles.Contains(shardingSettings.Role)) {