Fix issue when adding new peers

[controller.git] / opendaylight / md-sal / sal-akka-raft / src / main / java / org / opendaylight / controller / cluster / example / ExampleActor.java

diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java
index 914af5d9eb1e69f612e96f1f9592c468f9a2315d..8d4d5e48c81c6a91d2c089b0275f561575ee0baf 100644 (file)
--- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java
@@ -50,7 +50,9 @@ public class ExampleActor extends RaftActor {
                 String persistId = Long.toString(persistIdentifier++);
                 persistData(getSender(), persistId, message);
             } else {
                 String persistId = Long.toString(persistIdentifier++);
                 persistData(getSender(), persistId, message);
             } else {

-                getLeader().forward(message, getContext());
+                if(getLeader() != null) {
+                    getLeader().forward(message, getContext());
+                }

             }
 
         } else if (message instanceof PrintState) {
             }
 
         } else if (message instanceof PrintState) {