raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Rolling update when adding akka-cluster-typed dependency, #27191 (#27210)

Browse source
This commit is contained in:
Patrik Nordwall 2019-06-26 15:47:15 +01:00 • committed by Arnout Engelen
parent 50e99e08d8
commit 4e52432706
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-cluster-typed/src/main/scala/akka/cluster/typed/internal/receptionist/ClusterReceptionistConfigCompatChecker.scala
View file

@ -5,7 +5,7 @@
package akka.cluster.typed.internal.receptionist
import akka.annotation.InternalApi
import akka.cluster.{ ConfigValidation, JoinConfigCompatChecker }
import akka.cluster.{ ConfigValidation, JoinConfigCompatChecker, Valid }
import com.typesafe.config.Config
/**
@ -19,5 +19,8 @@ final class ClusterReceptionistConfigCompatChecker extends JoinConfigCompatCheck
override def requiredKeys = "akka.cluster.typed.receptionist.distributed-key-count" :: Nil
override def check(toCheck: Config, actualConfig: Config): ConfigValidation =
JoinConfigCompatChecker.fullMatch(requiredKeys, toCheck, actualConfig)
if (toCheck.hasPath(requiredKeys.head))
JoinConfigCompatChecker.fullMatch(requiredKeys, toCheck, actualConfig)
else
Valid // support for rolling update, property doesn't exist in previous versions
}