X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fbehaviors%2FFollower.java;fp=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fbehaviors%2FFollower.java;h=9dd630aade8a5e2e0a8265aa69564ceaace63cd4;hp=a05fb5d7efcebd764d4c2a9e3bbe28b98e71b4cc;hb=921b03062549b0977b83d1e2897d05801ea0b427;hpb=77c1a329c244eb5756f47723cf0bbf2cb6889408 diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Follower.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Follower.java index a05fb5d7ef..9dd630aade 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Follower.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/Follower.java @@ -165,12 +165,11 @@ public class Follower extends AbstractRaftActorBehavior { leaderId = appendEntries.getLeaderId(); leaderPayloadVersion = appendEntries.getPayloadVersion(); - if (appendEntries.getLeaderAddress().isPresent()) { - final String address = appendEntries.getLeaderAddress().orElseThrow(); - log.debug("New leader address: {}", address); - - context.setPeerAddress(leaderId, address); - context.getConfigParams().getPeerAddressResolver().setResolved(leaderId, address); + final var leaderAddress = appendEntries.leaderAddress(); + if (leaderAddress != null) { + log.debug("New leader address: {}", leaderAddress); + context.setPeerAddress(leaderId, leaderAddress); + context.getConfigParams().getPeerAddressResolver().setResolved(leaderId, leaderAddress); } // First check if the logs are in sync or not