- notificationManager = QueuedNotificationManager.create(
- executor, MANAGER_INVOKER, maxQueueSize, "DataTreeChangeListenerQueueMgr");
+ notificationManager = QueuedNotificationManager.create(executor, (listener, notifications) -> {
+ if (!listener.isClosed()) {
+ listener.getInstance().onDataTreeChanged(notifications);
+ }
+ }, maxQueueSize, "DataTreeChangeListenerQueueMgr");