X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fmessages%2FRegisterDataTreeChangeListener.java;h=e091b5bd0ffcb8c99759c53c2628facf0201dfa1;hb=7a38f0591bc527178510d749ae361e317dcc9788;hp=1f457780e5fa16266ea75247892630d8208299fd;hpb=925cb4a228d0fda99c7bfeb432eb25285a223887;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java index 1f457780e5..e091b5bd0f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java @@ -7,13 +7,14 @@ */ package org.opendaylight.controller.cluster.datastore.messages; +import akka.actor.ActorPath; import akka.actor.ActorRef; import com.google.common.base.Preconditions; import java.io.Externalizable; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; -import org.opendaylight.controller.cluster.datastore.utils.SerializationUtils; +import org.opendaylight.controller.cluster.datastore.node.utils.stream.SerializationUtils; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; /** @@ -26,6 +27,10 @@ public final class RegisterDataTreeChangeListener implements Externalizable, Lis private YangInstanceIdentifier path; private boolean registerOnAllInstances; + public RegisterDataTreeChangeListener() { + // For Externalizable + } + public RegisterDataTreeChangeListener(final YangInstanceIdentifier path, final ActorRef dataTreeChangeListenerPath, final boolean registerOnAllInstances) { this.path = Preconditions.checkNotNull(path); @@ -38,8 +43,9 @@ public final class RegisterDataTreeChangeListener implements Externalizable, Lis return path; } - public ActorRef getDataTreeChangeListenerPath() { - return dataTreeChangeListenerPath; + @Override + public ActorPath getListenerActorPath() { + return dataTreeChangeListenerPath.path(); } @Override @@ -60,4 +66,10 @@ public final class RegisterDataTreeChangeListener implements Externalizable, Lis path = SerializationUtils.deserializePath(in); registerOnAllInstances = in.readBoolean(); } + + @Override + public String toString() { + return "RegisterDataTreeChangeListener [path=" + path + ", registerOnAllInstances=" + registerOnAllInstances + + ", dataTreeChangeListenerPath=" + dataTreeChangeListenerPath + "]"; + } }