InMemoryDOMStoreTreeChangePublisher(final ExecutorService listenerExecutor, final int maxQueueSize) {
notificationManager = QueuedNotificationManager.create(listenerExecutor, (listener, notifications) -> {
- // FIXME: we are not checking for listener being closed
- listener.getInstance().onDataTreeChanged(notifications);
+ if (!listener.isClosed()) {
+ listener.getInstance().onDataTreeChanged(notifications);
+ }
}, maxQueueSize, "DataTreeChangeListenerQueueMgr");
}