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%2FDataChangeListenerSupport.java;h=51ab2aa57d49d29cc139a30a2653b3f8c449c5a4;hb=047566574ea74d1dfe24fa8075f8ba137faa698c;hp=6b0d8294d40313f3142cc9024722c827d9ebc41c;hpb=ec870dee9bacb971f11bc747b69e84ac37f5d746;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataChangeListenerSupport.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataChangeListenerSupport.java index 6b0d8294d4..51ab2aa57d 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataChangeListenerSupport.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataChangeListenerSupport.java @@ -11,14 +11,12 @@ import akka.actor.ActorRef; import akka.actor.ActorSelection; import org.opendaylight.controller.cluster.datastore.actors.DataTreeNotificationListenerRegistrationActor; import org.opendaylight.controller.cluster.datastore.messages.RegisterChangeListener; -import org.opendaylight.controller.cluster.datastore.messages.RegisterChangeListenerReply; import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeListener; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; final class DataChangeListenerSupport extends AbstractDataListenerSupport< - AsyncDataChangeListener>, RegisterChangeListener, - DelayedDataChangeListenerRegistration> { + AsyncDataChangeListener>, RegisterChangeListener> { DataChangeListenerSupport(final Shard shard) { super(shard); @@ -40,17 +38,6 @@ final class DataChangeListenerSupport extends AbstractDataListenerSupport< removeListenerActor(listenerActor)), ActorRef.noSender())); } - @Override - protected DelayedDataChangeListenerRegistration newDelayedListenerRegistration(RegisterChangeListener message, - ActorRef registrationActor) { - return new DelayedDataChangeListenerRegistration(message, registrationActor); - } - - @Override - protected Object newRegistrationReplyMessage(ActorRef registrationActor) { - return new RegisterChangeListenerReply(registrationActor); - } - @Override protected String logName() { return "registerDataChangeListener";