We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c7af6a5 commit 5891e03Copy full SHA for 5891e03
1 file changed
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardRegion.scala
@@ -768,7 +768,7 @@ private[akka] class ShardRegion(
768
// We only make one attempt to one candidate so as to not flood with registration messages
769
// Important since this is level-triggered (any membership change where the coordinator is on a
770
// not-up node) while registration is otherwise edge-triggered
771
- coordinatorSelection.lastOption.foreach(sendRegistrationMessage)
+ coordinatorSelection.headOption.foreach(sendRegistrationMessage)
772
773
if (!timers.isTimerActive(RegisterRetry)) {
774
nextRegistrationDelay = initRegistrationDelay
0 commit comments