X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Futils%2FMessageCollectorActor.java;h=68d6b619cd43bc6aa2d1ce582e32b2eb0bb03d4e;hp=e947aede3b7bec14bec92abeb6ae77e33c68c2d8;hb=97542f208267cb5392fc8c8d9baf6c1d3ee4ae32;hpb=e1eca73a5ae2ffae8dd78c6fe5281cd2f45d5ef3 diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/utils/MessageCollectorActor.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/utils/MessageCollectorActor.java index e947aede3b..68d6b619cd 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/utils/MessageCollectorActor.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/utils/MessageCollectorActor.java @@ -38,12 +38,9 @@ public class MessageCollectorActor extends UntypedActor { private final List messages = new ArrayList<>(); @Override public void onReceive(Object message) throws Exception { - if (message.equals(ARE_YOU_READY)) { + if (ARE_YOU_READY.equals(message)) { getSender().tell("yes", getSelf()); - return; - } - - if (GET_ALL_MESSAGES.equals(message)) { + } else if (GET_ALL_MESSAGES.equals(message)) { getSender().tell(new ArrayList<>(messages), getSelf()); } else if (CLEAR_MESSAGES.equals(message)) { clear();