- ListenerRegistration<DOMDataTreeChangeListener> createDelegate(final RegisterDataTreeChangeListener message) {
- ActorSelection dataChangeListenerPath = shard.getContext().system().actorSelection(
- message.getDataTreeChangeListenerPath().path());
-
- // Notify the listener if notifications should be enabled or not
- // If this shard is the leader then it will enable notifications else
- // it will not
- dataChangeListenerPath.tell(new EnableNotification(true), shard.getSelf());
-
- // Now store a reference to the data change listener so it can be notified
- // at a later point if notifications should be enabled or disabled
- actors.add(dataChangeListenerPath);
+ protected DelayedDataTreeListenerRegistration newDelayedListenerRegistration(RegisterDataTreeChangeListener message) {
+ return new DelayedDataTreeListenerRegistration(message);
+ }