X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FRemoteRpcProviderTest.java;h=45fc9ffbbc7f4eea33586935a82b74a7f5ed1f20;hp=76e63c4e1d3da01d8aa7ce7a864f360d6f6b4dfe;hb=c55d6cccb33e3de942e521e31404a60c1738b768;hpb=ea13216ab31269d4d0b822efb346a00ad82276ef;ds=sidebyside diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderTest.java b/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderTest.java index 76e63c4e1d..45fc9ffbbc 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderTest.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/test/java/org/opendaylight/controller/remote/rpc/RemoteRpcProviderTest.java @@ -9,7 +9,6 @@ package org.opendaylight.controller.remote.rpc; import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.when; import akka.actor.ActorRef; import akka.actor.ActorSystem; @@ -23,7 +22,6 @@ import org.junit.BeforeClass; import org.junit.Test; import org.opendaylight.controller.md.sal.dom.api.DOMRpcProviderService; import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; -import org.opendaylight.controller.sal.core.api.Broker; import scala.concurrent.Await; import scala.concurrent.duration.Duration; @@ -49,11 +47,9 @@ public class RemoteRpcProviderTest { @Test public void testRemoteRpcProvider() throws Exception { try (final RemoteRpcProvider rpcProvider = new RemoteRpcProvider(system, mock(DOMRpcProviderService.class), - new RemoteRpcProviderConfig(system.settings().config()))) { - final Broker.ProviderSession session = mock(Broker.ProviderSession.class); - when(session.getService(DOMRpcService.class)).thenReturn(mock(DOMRpcService.class)); + mock(DOMRpcService.class), new RemoteRpcProviderConfig(system.settings().config()))) { - rpcProvider.onSessionInitiated(session); + rpcProvider.start(); final ActorRef actorRef = Await.result( system.actorSelection(moduleConfig.getRpcManagerPath()).resolveOne(