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%2Fexample%2FExampleActor.java;h=8d4d5e48c81c6a91d2c089b0275f561575ee0baf;hp=914af5d9eb1e69f612e96f1f9592c468f9a2315d;hb=cbf101a2dd94747d62a3078d6e50433096cccd4a;hpb=b725909c696c8d40006a6297dc54a467fddcf6b3 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 914af5d9eb..8d4d5e48c8 100644 --- 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 { - getLeader().forward(message, getContext()); + if(getLeader() != null) { + getLeader().forward(message, getContext()); + } } } else if (message instanceof PrintState) {