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%2Fdatabroker%2Factors%2Fdds%2FModuleShardBackendResolverTest.java;h=bedd4a9283ec4d4710559e7f971418021f2964b7;hp=05145899b47ecae34adbe98e26ab81da7d541d15;hb=12fcdfe39aa26dcba7fd3bb4d4c68e3d02e65c51;hpb=52cf6acb8f951682c1df5458902974b4602cea8e diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/ModuleShardBackendResolverTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/ModuleShardBackendResolverTest.java index 05145899b4..bedd4a9283 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/ModuleShardBackendResolverTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/databroker/actors/dds/ModuleShardBackendResolverTest.java @@ -13,8 +13,8 @@ import static org.mockito.Mockito.when; import akka.actor.ActorRef; import akka.actor.ActorSelection; import akka.actor.ActorSystem; -import akka.testkit.JavaTestKit; import akka.testkit.TestProbe; +import akka.testkit.javadsl.TestKit; import java.util.Collections; import java.util.concurrent.CompletionStage; import java.util.concurrent.ExecutionException; @@ -60,7 +60,7 @@ public class ModuleShardBackendResolverTest { private DataTree dataTree; @Before - public void setUp() throws Exception { + public void setUp() { MockitoAnnotations.initMocks(this); system = ActorSystem.apply(); contextProbe = new TestProbe(system, "context"); @@ -73,19 +73,19 @@ public class ModuleShardBackendResolverTest { } @After - public void tearDown() throws Exception { - JavaTestKit.shutdownActorSystem(system); + public void tearDown() { + TestKit.shutdownActorSystem(system); } @Test - public void testResolveShardForPathNonNullCookie() throws Exception { + public void testResolveShardForPathNonNullCookie() { when(shardStrategy.findShard(YangInstanceIdentifier.EMPTY)).thenReturn("default"); final Long cookie = moduleShardBackendResolver.resolveShardForPath(YangInstanceIdentifier.EMPTY); Assert.assertEquals(0L, cookie.longValue()); } @Test - public void testResolveShardForPathNullCookie() throws Exception { + public void testResolveShardForPathNullCookie() { when(shardStrategy.findShard(YangInstanceIdentifier.EMPTY)).thenReturn("foo"); final Long cookie = moduleShardBackendResolver.resolveShardForPath(YangInstanceIdentifier.EMPTY); Assert.assertEquals(1L, cookie.longValue()); @@ -110,16 +110,14 @@ public class ModuleShardBackendResolverTest { public void testGetBackendInfoFail() throws Exception { final CompletionStage i = moduleShardBackendResolver.getBackendInfo(0L); final ConnectClientRequest req = contextProbe.expectMsgClass(ConnectClientRequest.class); - final RuntimeRequestException cause = new RuntimeRequestException("fail", new RuntimeException()); - final ConnectClientFailure response = - req.toRequestFailure(cause); + final RuntimeException cause = new RuntimeException(); + final ConnectClientFailure response = req.toRequestFailure(new RuntimeRequestException("fail", cause)); contextProbe.reply(response); final CompletionStage stage = moduleShardBackendResolver.getBackendInfo(0L); final ExecutionException caught = TestUtils.assertOperationThrowsException(() -> TestUtils.getWithTimeout(stage.toCompletableFuture()), ExecutionException.class); - Assert.assertNotNull(caught.getCause()); - Assert.assertEquals(cause, caught.getCause().getCause()); + Assert.assertEquals(cause, caught.getCause()); } @Test