+ void notifyOfInitialData(DataChangeListenerRegistration<AsyncDataChangeListener<YangInstanceIdentifier,
+ NormalizedNode<?, ?>>> listenerReg, Optional<DataTreeCandidate> currentState) {
+
+ if(currentState.isPresent()) {
+ ListenerTree localListenerTree = ListenerTree.create();
+ localListenerTree.registerDataChangeListener(listenerReg.getPath(), listenerReg.getInstance(),
+ listenerReg.getScope());
+
+ ResolveDataChangeEventsTask.create(currentState.get(), localListenerTree).resolve(MANAGER);
+ }
+ }
+
+ void notifyOfInitialData(final YangInstanceIdentifier path, final DOMDataTreeChangeListener listener,
+ final Optional<DataTreeCandidate> currentState) {
+ if(currentState.isPresent()) {
+ ShardDataTreeChangePublisher localTreeChangePublisher = new ShardDataTreeChangePublisher();
+ localTreeChangePublisher.registerTreeChangeListener(path, listener);
+ localTreeChangePublisher.publishChanges(currentState.get());
+ }
+ }
+