File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
akka-cluster-sharding/src/main/scala/akka/cluster/sharding Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -792,8 +792,10 @@ private[akka] class ShardRegion(
792792 }
793793
794794 def changeMembers (newMembers : immutable.SortedSet [Member ]): Unit = {
795- val before = membersByAge.headOption
795+ val oldMembers = membersByAge
796+ val before = oldMembers.headOption
796797 val after = newMembers.headOption
798+ membersByAge = newMembers
797799 // NB: equaliity check is on uniqueAddress, not status etc.
798800 if (before != after) {
799801 if (log.isDebugEnabled)
@@ -807,11 +809,10 @@ private[akka] class ShardRegion(
807809 } else if (coordinator.isEmpty) {
808810 // NB: resets registration retry backoff, but the situation has changed
809811 startRegistration()
810- } else if (coordinatorStatus(membersByAge ) != coordinatorStatus(newMembers)) {
812+ } else if (coordinatorStatus(oldMembers ) != coordinatorStatus(newMembers)) {
811813 // coordinator status changed
812814 reRegisterIfCoordinatorNotUp()
813815 }
814- membersByAge = newMembers
815816 }
816817
817818 def receive : Receive = {
You can’t perform that action at this time.
0 commit comments