import akka.actor.ActorSelection;
import org.opendaylight.controller.cluster.datastore.actors.DataTreeNotificationListenerRegistrationActor;
import org.opendaylight.controller.cluster.datastore.messages.RegisterDataTreeChangeListener;
-import org.opendaylight.controller.cluster.datastore.messages.RegisterDataTreeChangeListenerReply;
import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener;
final class DataTreeChangeListenerSupport extends AbstractDataListenerSupport<DOMDataTreeChangeListener,
- RegisterDataTreeChangeListener, DelayedDataTreeListenerRegistration> {
+ RegisterDataTreeChangeListener> {
DataTreeChangeListenerSupport(final Shard shard) {
super(shard);
DOMDataTreeChangeListener listener = new ForwardingDataTreeChangeListener(listenerActor);
- log().debug("{}: Registering for path {}", persistenceId(), message.getPath());
+ log().debug("{}: Registering listenerActor {} for path {}", persistenceId(), listenerActor, message.getPath());
final ShardDataTree shardDataTree = getShard().getDataStore();
shardDataTree.registerTreeChangeListener(message.getPath(),
removeListenerActor(listenerActor)), ActorRef.noSender()));
}
- @Override
- protected DelayedDataTreeListenerRegistration newDelayedListenerRegistration(
- RegisterDataTreeChangeListener message, ActorRef registrationActor) {
- return new DelayedDataTreeListenerRegistration(message, registrationActor);
- }
-
- @Override
- protected Object newRegistrationReplyMessage(ActorRef registrationActor) {
- return new RegisterDataTreeChangeListenerReply(registrationActor);
- }
-
@Override
protected String logName() {
return "registerTreeChangeListener";