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

Merge pull request #27637 from akka/wip-enum-patriknw

Browse source 
fix deprecation warning for protobuf enum
This commit is contained in:
Patrik Nordwall 2019-09-05 20:52:00 +02:00 • committed by GitHub
commit 4020036eb6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster/src/main/scala/akka/cluster/protobuf/ClusterMessageSerializer.scala
View file

@ -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()