Fixes log and uses cluster sharding LeaseSettings, if configured, i…

…n ShardedDaemonProcess (#6058)
akkadotnet · Aug 8, 2022 · 03de287 · 03de287
1 parent f571e26
commit 03de287
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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<int, Props> 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))
             {