X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fmessaging%2FMessageSliceReplyTest.java;h=8b661f68d7e9f5275666a645edbd9f603753b42b;hb=HEAD;hp=fa31fbfeef60dd98348878f922945aa2f4c5b20f;hpb=3582bb6dbc506b0c79dd3e4b4f791f4e17cd3103;p=controller.git diff --git a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSliceReplyTest.java b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSliceReplyTest.java index fa31fbfeef..8b661f68d7 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSliceReplyTest.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/messaging/MessageSliceReplyTest.java @@ -8,13 +8,15 @@ package org.opendaylight.controller.cluster.messaging; import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.assertTrue; import akka.actor.ActorSystem; import akka.actor.ExtendedActorSystem; import akka.serialization.JavaSerializer; -import akka.testkit.JavaTestKit; import akka.testkit.TestProbe; -import org.apache.commons.lang.SerializationUtils; +import akka.testkit.javadsl.TestKit; +import org.apache.commons.lang3.SerializationUtils; import org.junit.After; import org.junit.Before; import org.junit.Test; @@ -34,7 +36,7 @@ public class MessageSliceReplyTest { @After public void tearDown() { - JavaTestKit.shutdownActorSystem(actorSystem, Boolean.TRUE); + TestKit.shutdownActorSystem(actorSystem, true); } @Test @@ -46,26 +48,26 @@ public class MessageSliceReplyTest { private void testSuccess() { MessageSliceReply expected = MessageSliceReply.success(new StringIdentifier("test"), 3, TestProbe.apply(actorSystem).ref()); - MessageSliceReply cloned = (MessageSliceReply) SerializationUtils.clone(expected); + MessageSliceReply cloned = SerializationUtils.clone(expected); assertEquals("getIdentifier", expected.getIdentifier(), cloned.getIdentifier()); assertEquals("getSliceIndex", expected.getSliceIndex(), cloned.getSliceIndex()); assertEquals("getSendTo", expected.getSendTo(), cloned.getSendTo()); - assertEquals("getFailure present", Boolean.FALSE, cloned.getFailure().isPresent()); + assertFalse("getFailure present", cloned.getFailure().isPresent()); } private void testFailure() { MessageSliceReply expected = MessageSliceReply.failed(new StringIdentifier("test"), new MessageSliceException("mock", true), TestProbe.apply(actorSystem).ref()); - MessageSliceReply cloned = (MessageSliceReply) SerializationUtils.clone(expected); + MessageSliceReply cloned = SerializationUtils.clone(expected); assertEquals("getIdentifier", expected.getIdentifier(), cloned.getIdentifier()); assertEquals("getSliceIndex", expected.getSliceIndex(), cloned.getSliceIndex()); assertEquals("getSendTo", expected.getSendTo(), cloned.getSendTo()); - assertEquals("getFailure present", Boolean.TRUE, cloned.getFailure().isPresent()); - assertEquals("getFailure message", expected.getFailure().get().getMessage(), - cloned.getFailure().get().getMessage()); - assertEquals("getFailure isRetriable", expected.getFailure().get().isRetriable(), - cloned.getFailure().get().isRetriable()); + assertTrue("getFailure present", cloned.getFailure().isPresent()); + assertEquals("getFailure message", expected.getFailure().orElseThrow().getMessage(), + cloned.getFailure().orElseThrow().getMessage()); + assertEquals("getFailure isRetriable", expected.getFailure().orElseThrow().isRetriable(), + cloned.getFailure().orElseThrow().isRetriable()); } }