fixed bug with leader changes

akkadotnet · Sep 26, 2014 · 8a6166f · 8a6166f
1 parent bc7ca2a
commit 8a6166f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/core/Akka.Cluster/ClusterReadView.cs b/src/core/Akka.Cluster/ClusterReadView.cs
@@ -132,7 +132,7 @@ public EventBusListener(Cluster cluster, ClusterReadView readView)
                         })
                         .With<ClusterEvent.RoleLeaderChanged>(changed =>
                         {
-                            State = State.Copy(roleLeaderMap: State.RoleLeaderMap.Add(changed.Role, changed.Leader));
+                            State = State.Copy(roleLeaderMap: State.RoleLeaderMap.SetItem(changed.Role, changed.Leader));
                         })
                         .With<ClusterEvent.CurrentInternalStats>(stats =>
                         {