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=ad8a69f79ea8783dd8f75afdbd7bbb865bee2508;hb=2fd1fa721510a30f58b3bc277deb05fce58badd6;hpb=e9fc7e7ed2b13d274518d6a872ab67749ef4507a 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 ad8a69f79e..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; @@ -30,15 +29,12 @@ public class RoleChangeListenerActorTest extends AbstractActorTest { @Test public void testRegisterRoleChangeListenerOnStart() { - new TestKit(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