2 * Copyright (c) 2017 Inocybe Technologies and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.cluster.messaging;
10 import static org.junit.Assert.assertEquals;
12 import akka.actor.ActorSystem;
13 import akka.actor.ExtendedActorSystem;
14 import akka.serialization.JavaSerializer;
15 import akka.testkit.JavaTestKit;
16 import akka.testkit.TestProbe;
17 import org.apache.commons.lang.SerializationUtils;
18 import org.junit.After;
19 import org.junit.Before;
20 import org.junit.Test;
23 * Unit tests for MessageSliceReply.
25 * @author Thomas Pantelis
27 public class MessageSliceReplyTest {
28 private final ActorSystem actorSystem = ActorSystem.create("test");
32 JavaSerializer.currentSystem().value_$eq((ExtendedActorSystem) actorSystem);
36 public void tearDown() {
37 JavaTestKit.shutdownActorSystem(actorSystem, Boolean.TRUE);
41 public void testSerialization() {
46 private void testSuccess() {
47 MessageSliceReply expected = MessageSliceReply.success(new StringIdentifier("test"), 3,
48 TestProbe.apply(actorSystem).ref());
49 MessageSliceReply cloned = (MessageSliceReply) SerializationUtils.clone(expected);
51 assertEquals("getIdentifier", expected.getIdentifier(), cloned.getIdentifier());
52 assertEquals("getSliceIndex", expected.getSliceIndex(), cloned.getSliceIndex());
53 assertEquals("getSendTo", expected.getSendTo(), cloned.getSendTo());
54 assertEquals("getFailure present", Boolean.FALSE, cloned.getFailure().isPresent());
57 private void testFailure() {
58 MessageSliceReply expected = MessageSliceReply.failed(new StringIdentifier("test"),
59 new MessageSliceException("mock", true), TestProbe.apply(actorSystem).ref());
60 MessageSliceReply cloned = (MessageSliceReply) SerializationUtils.clone(expected);
62 assertEquals("getIdentifier", expected.getIdentifier(), cloned.getIdentifier());
63 assertEquals("getSliceIndex", expected.getSliceIndex(), cloned.getSliceIndex());
64 assertEquals("getSendTo", expected.getSendTo(), cloned.getSendTo());
65 assertEquals("getFailure present", Boolean.TRUE, cloned.getFailure().isPresent());
66 assertEquals("getFailure message", expected.getFailure().get().getMessage(),
67 cloned.getFailure().get().getMessage());
68 assertEquals("getFailure isRetriable", expected.getFailure().get().isRetriable(),
69 cloned.getFailure().get().isRetriable());