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 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;
private static final long serialVersionUID = 1L;
private ActorRef dataTreeChangeListenerPath;
private YangInstanceIdentifier path;
private static final long serialVersionUID = 1L;
private ActorRef dataTreeChangeListenerPath;
private YangInstanceIdentifier path;
- public RegisterDataTreeChangeListener(final YangInstanceIdentifier path, final ActorRef dataTreeChangeListenerPath) {
+ public RegisterDataTreeChangeListener() {
+ // For Externalizable
+ }
+
+ public RegisterDataTreeChangeListener(final YangInstanceIdentifier path, final ActorRef dataTreeChangeListenerPath,
+ final boolean registerOnAllInstances) {
this.path = Preconditions.checkNotNull(path);
this.dataTreeChangeListenerPath = Preconditions.checkNotNull(dataTreeChangeListenerPath);
this.path = Preconditions.checkNotNull(path);
this.dataTreeChangeListenerPath = Preconditions.checkNotNull(dataTreeChangeListenerPath);
- public ActorRef getDataTreeChangeListenerPath() {
- return dataTreeChangeListenerPath;
+ @Override
+ public ActorPath getListenerActorPath() {
+ return dataTreeChangeListenerPath.path();
+ }
+
+ @Override
+ public boolean isRegisterOnAllInstances() {
+ return registerOnAllInstances;
}
@Override
public void writeExternal(final ObjectOutput out) throws IOException {
out.writeObject(dataTreeChangeListenerPath);
SerializationUtils.serializePath(path, out);
}
@Override
public void writeExternal(final ObjectOutput out) throws IOException {
out.writeObject(dataTreeChangeListenerPath);
SerializationUtils.serializePath(path, out);
}
@Override
public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
dataTreeChangeListenerPath = (ActorRef) in.readObject();
path = SerializationUtils.deserializePath(in);
}
@Override
public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
dataTreeChangeListenerPath = (ActorRef) in.readObject();
path = SerializationUtils.deserializePath(in);
+ registerOnAllInstances = in.readBoolean();
+ }
+
+ @Override
+ public String toString() {
+ return "RegisterDataTreeChangeListener [path=" + path + ", registerOnAllInstances=" + registerOnAllInstances
+ + ", dataTreeChangeListenerPath=" + dataTreeChangeListenerPath + "]";