X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fsharding%2FRoleChangeListenerActorTest.java;h=ca8c05ddcbb97b81946d1b633d34f4b4c1fb3b7c;hp=978cc27c9a249cbbf8846eae3b3e6ba3190d58ed;hb=2fd1fa721510a30f58b3bc277deb05fce58badd6;hpb=d69af1f79ae4630be8c4d65b98096aa27b1665b6 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/sharding/RoleChangeListenerActorTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/sharding/RoleChangeListenerActorTest.java index 978cc27c9a..ca8c05ddcb 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/sharding/RoleChangeListenerActorTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/sharding/RoleChangeListenerActorTest.java @@ -5,12 +5,11 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.cluster.sharding; import static akka.actor.ActorRef.noSender; -import static org.mockito.Matchers.any; -import static org.mockito.Matchers.eq; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; import static org.mockito.Mockito.doNothing; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.timeout; @@ -18,7 +17,7 @@ import static org.mockito.Mockito.verify; import akka.actor.ActorRef; import akka.actor.Props; -import akka.testkit.JavaTestKit; +import akka.testkit.javadsl.TestKit; import org.junit.Test; import org.opendaylight.controller.cluster.datastore.AbstractActorTest; import org.opendaylight.controller.cluster.dom.api.LeaderLocation; @@ -30,15 +29,12 @@ public class RoleChangeListenerActorTest extends AbstractActorTest { @Test public void testRegisterRoleChangeListenerOnStart() { - new JavaTestKit(getSystem()) { - { - final LeaderLocationListener listener = mock(LeaderLocationListener.class); - final Props props = RoleChangeListenerActor.props(getRef(), listener); - - getSystem().actorOf(props, "testRegisterRoleChangeListenerOnStart"); - expectMsgClass(RegisterRoleChangeListener.class); - } - }; + final TestKit testKit = new TestKit(getSystem()); + final LeaderLocationListener listener = mock(LeaderLocationListener.class); + final Props props = RoleChangeListenerActor.props(testKit.getRef(), listener); + + getSystem().actorOf(props, "testRegisterRoleChangeListenerOnStart"); + testKit.expectMsgClass(RegisterRoleChangeListener.class); } @Test @@ -57,6 +53,5 @@ public class RoleChangeListenerActorTest extends AbstractActorTest { subject.tell(new LeaderStateChanged("member-1", "member-2", (short) 0), noSender()); verify(listener, timeout(5000)).onLeaderLocationChanged(eq(LeaderLocation.REMOTE)); - } } \ No newline at end of file