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%2FRaftActorContextImpl.java;h=f0236a1abfa9cf0c12a9e6384f76ab4dc2df1333;hp=74f02b5ef5146ed7d527f83552c298276a6d6485;hb=2eddbcc5db186af5b5feacfe5d7056e2f3dccd38;hpb=c09dc45ec6f475fbb5398d6fec2182738e73483f diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java index 74f02b5ef5..f0236a1abf 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java @@ -8,7 +8,6 @@ package org.opendaylight.controller.cluster.raft; -import static com.google.common.base.Preconditions.checkState; import akka.actor.ActorRef; import akka.actor.ActorSelection; import akka.actor.ActorSystem; @@ -176,11 +175,12 @@ public class RaftActorContextImpl implements RaftActorContext { return null; } - @Override public void setPeerAddress(String peerId, String peerAddress) { - LOG.info("Peer address for peer {} set to {}", peerId, peerAddress); - checkState(peerAddresses.containsKey(peerId), peerId + " is unknown"); - - peerAddresses.put(peerId, peerAddress); + @Override + public void setPeerAddress(String peerId, String peerAddress) { + if(peerAddresses.containsKey(peerId)) { + LOG.info("Peer address for peer {} set to {}", peerId, peerAddress); + peerAddresses.put(peerId, peerAddress); + } } @Override