From 4edbcde28072ab7c275937092254e75a01b872c8 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Thu, 5 Sep 2019 15:55:55 +0200 Subject: [PATCH] fix deprecation warning for protobuf enum --- .../akka/cluster/protobuf/ClusterMessageSerializer.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-cluster/src/main/scala/akka/cluster/protobuf/ClusterMessageSerializer.scala b/akka-cluster/src/main/scala/akka/cluster/protobuf/ClusterMessageSerializer.scala index 8239dad95f..9da341db87 100644 --- a/akka-cluster/src/main/scala/akka/cluster/protobuf/ClusterMessageSerializer.scala +++ b/akka-cluster/src/main/scala/akka/cluster/protobuf/ClusterMessageSerializer.scala @@ -400,7 +400,7 @@ final class ClusterMessageSerializer(val system: ExtendedActorSystem) cm.Member.newBuilder .setAddressIndex(mapUniqueAddress(member.uniqueAddress)) .setUpNumber(member.upNumber) - .setStatus(cm.MemberStatus.valueOf(memberStatusToInt(member.status))) + .setStatus(cm.MemberStatus.forNumber(memberStatusToInt(member.status))) .addAllRolesIndexes(member.roles.map(mapRole).asJava) def reachabilityToProto(reachability: Reachability): Iterable[cm.ObserverReachability.Builder] = { @@ -413,7 +413,7 @@ final class ClusterMessageSerializer(val system: ExtendedActorSystem) cm.SubjectReachability .newBuilder() .setAddressIndex(mapUniqueAddress(r.subject)) - .setStatus(cm.ReachabilityStatus.valueOf(reachabilityStatusToInt(r.status))) + .setStatus(cm.ReachabilityStatus.forNumber(reachabilityStatusToInt(r.status))) .setVersion(r.version)) cm.ObserverReachability .newBuilder()