1 package org.opendaylight.controller.cluster.datastore.messages;
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;
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;
15 public class RegisterChangeListenerReplyTest extends AbstractActorTest {
17 private TestActorFactory factory;
22 factory = new TestActorFactory(getSystem());
26 public void shutDown(){
31 public void testToSerializable(){
32 TestActorRef<Actor> testActor = factory.createTestActor(MessageCollectorActor.props());
34 RegisterChangeListenerReply registerChangeListenerReply = new RegisterChangeListenerReply(testActor);
36 ListenerRegistrationMessages.RegisterChangeListenerReply serialized
37 = registerChangeListenerReply.toSerializable();
39 assertEquals(Serialization.serializedActorPath(testActor), serialized.getListenerRegistrationPath());
43 public void testFromSerializable(){
44 TestActorRef<Actor> testActor = factory.createTestActor(MessageCollectorActor.props());
46 RegisterChangeListenerReply registerChangeListenerReply = new RegisterChangeListenerReply(testActor);
48 ListenerRegistrationMessages.RegisterChangeListenerReply serialized
49 = registerChangeListenerReply.toSerializable();
52 RegisterChangeListenerReply fromSerialized
53 = RegisterChangeListenerReply.fromSerializable(getSystem(), serialized);
55 assertEquals(testActor.path().toString(), fromSerialized.getListenerRegistrationPath().toString());