X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FTestActorFactory.java;h=ea38c16acc95fc5110165feba04d504f5434fbb0;hb=refs%2Fchanges%2F22%2F65622%2F11;hp=639436d026c04c5c96169b3fc330a120484896ba;hpb=283929615619b09a664fd46bd13e19cdb163ec4d;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/TestActorFactory.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/TestActorFactory.java index 639436d026..ea38c16acc 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/TestActorFactory.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/TestActorFactory.java @@ -8,14 +8,6 @@ package org.opendaylight.controller.cluster.raft; -/* - * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ - import akka.actor.Actor; import akka.actor.ActorIdentity; import akka.actor.ActorRef; @@ -26,8 +18,8 @@ import akka.actor.InvalidActorNameException; import akka.actor.PoisonPill; import akka.actor.Props; import akka.pattern.Patterns; -import akka.testkit.JavaTestKit; import akka.testkit.TestActorRef; +import akka.testkit.javadsl.TestKit; import akka.util.Timeout; import com.google.common.base.Stopwatch; import com.google.common.util.concurrent.Uninterruptibles; @@ -181,15 +173,15 @@ public class TestActorFactory implements AutoCloseable { return prefix + actorCount++; } - public void killActor(ActorRef actor, JavaTestKit kit) { + public void killActor(ActorRef actor, TestKit kit) { killActor(actor, kit, true); } - private void killActor(ActorRef actor, JavaTestKit kit, boolean remove) { + private void killActor(ActorRef actor, TestKit kit, boolean remove) { LOG.info("Killing actor {}", actor); kit.watch(actor); actor.tell(PoisonPill.getInstance(), ActorRef.noSender()); - kit.expectTerminated(JavaTestKit.duration("5 seconds"), actor); + kit.expectTerminated(kit.duration("5 seconds"), actor); if (remove) { createdActors.remove(actor); @@ -202,7 +194,7 @@ public class TestActorFactory implements AutoCloseable { @Override public void close() { - JavaTestKit kit = new JavaTestKit(system); + TestKit kit = new TestKit(system); for (ActorRef actor : createdActors) { killActor(actor, kit, false); }