opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/messages/RegisterChangeListenerReplyTest.java

   1 package org.opendaylight.controller.cluster.datastore.messages;
   2
   3 import static junit.framework.TestCase.assertEquals;
   4 import akka.actor.Actor;
   5 import akka.serialization.Serialization;
   6 import akka.testkit.TestActorRef;
   7 import org.junit.After;
   8 import org.junit.Before;
   9 import org.junit.Test;
  10 import org.opendaylight.controller.cluster.datastore.AbstractActorTest;
  11 import org.opendaylight.controller.cluster.raft.TestActorFactory;
  12 import org.opendaylight.controller.cluster.raft.utils.MessageCollectorActor;
  13 import org.opendaylight.controller.protobuff.messages.registration.ListenerRegistrationMessages;
  14
  15 public class RegisterChangeListenerReplyTest extends AbstractActorTest {
  16
  17     private TestActorFactory factory;
  18
  19
  20     @Before
  21     public void setUp(){
  22         factory = new TestActorFactory(getSystem());
  23     }
  24
  25     @After
  26     public void shutDown(){
  27         factory.close();
  28     }
  29
  30     @Test
  31     public void testToSerializable(){
  32         TestActorRef<Actor> testActor = factory.createTestActor(MessageCollectorActor.props());
  33
  34         RegisterChangeListenerReply registerChangeListenerReply = new RegisterChangeListenerReply(testActor);
  35
  36         ListenerRegistrationMessages.RegisterChangeListenerReply serialized
  37                 = registerChangeListenerReply.toSerializable();
  38
  39         assertEquals(Serialization.serializedActorPath(testActor), serialized.getListenerRegistrationPath());
  40     }
  41
  42     @Test
  43     public void testFromSerializable(){
  44         TestActorRef<Actor> testActor = factory.createTestActor(MessageCollectorActor.props());
  45
  46         RegisterChangeListenerReply registerChangeListenerReply = new RegisterChangeListenerReply(testActor);
  47
  48         ListenerRegistrationMessages.RegisterChangeListenerReply serialized
  49                 = registerChangeListenerReply.toSerializable();
  50
  51
  52         RegisterChangeListenerReply fromSerialized
  53                 = RegisterChangeListenerReply.fromSerializable(getSystem(), serialized);
  54
  55         assertEquals(testActor.path().toString(), fromSerialized.getListenerRegistrationPath().toString());
  56     }
  57
  58 }