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<YangInstanceIdentifier, NormalizedNode<?, ?>>, RegisterChangeListener,
- DelayedDataChangeListenerRegistration> {
+ AsyncDataChangeListener<YangInstanceIdentifier, NormalizedNode<?, ?>>, RegisterChangeListener> {
DataChangeListenerSupport(final Shard shard) {
super(shard);
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";