X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2FRemoteRpcProviderTest.java;h=e1f93f8b390b6e9a3f12d773553ec8296100e13f;hb=f09d37ec4cce2411eaae11dde18f9ce2d2f14118;hp=1187365a85e15a754d426a666b582b3c604400d2;hpb=1a4a451d17d39b0dac45a70de9016bd4b0e6b249;p=controller.git 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 1187365a85..e1f93f8b39 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 @@ -49,23 +49,23 @@ public class RemoteRpcProviderTest { system = null; } - @Test - public void testRemoteRpcProvider() throws Exception { - final RemoteRpcProvider rpcProvider = new RemoteRpcProvider(system, mock(DOMRpcProviderService.class), - new RemoteRpcProviderConfig(system.settings().config())); - final Broker.ProviderSession session = mock(Broker.ProviderSession.class); - final SchemaService schemaService = mock(SchemaService.class); - when(schemaService.getGlobalContext()). thenReturn(mock(SchemaContext.class)); - when(session.getService(SchemaService.class)).thenReturn(schemaService); - when(session.getService(DOMRpcService.class)).thenReturn(mock(DOMRpcService.class)); + @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); + final SchemaService schemaService = mock(SchemaService.class); + when(schemaService.getGlobalContext()).thenReturn(mock(SchemaContext.class)); + when(session.getService(SchemaService.class)).thenReturn(schemaService); + when(session.getService(DOMRpcService.class)).thenReturn(mock(DOMRpcService.class)); - rpcProvider.onSessionInitiated(session); + rpcProvider.onSessionInitiated(session); - final ActorRef actorRef = Await.result( - system.actorSelection( - moduleConfig.getRpcManagerPath()).resolveOne(Duration.create(1, TimeUnit.SECONDS)), - Duration.create(2, TimeUnit.SECONDS)); + final ActorRef actorRef = Await.result( + system.actorSelection(moduleConfig.getRpcManagerPath()).resolveOne( + Duration.create(1, TimeUnit.SECONDS)), Duration.create(2, TimeUnit.SECONDS)); - Assert.assertTrue(actorRef.path().toString().contains(moduleConfig.getRpcManagerPath())); - } + Assert.assertTrue(actorRef.path().toString().contains(moduleConfig.getRpcManagerPath())); + } + } }