X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=dom%2Fmdsal-dom-inmemory-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fdom%2Fstore%2Finmemory%2FInMemoryDOMDataTreeShardChangePublisher.java;h=ccbf366f868f70a8441fefc6478da82a78a26152;hb=c71394328f488ea5f3bccf5ac8d42c8802cb637e;hp=a333033c90a3f5e92d98030f9db78351aedb5e3b;hpb=c77348ddc6ccebb90ef32b5e55f38e0997047f36;p=mdsal.git

diff --git a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShardChangePublisher.java b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShardChangePublisher.java
index a333033c90..ccbf366f86 100644
--- a/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShardChangePublisher.java
+++ b/dom/mdsal-dom-inmemory-datastore/src/main/java/org/opendaylight/mdsal/dom/store/inmemory/InMemoryDOMDataTreeShardChangePublisher.java
@@ -34,8 +34,9 @@ final class InMemoryDOMDataTreeShardChangePublisher extends AbstractDOMShardTree
                                             final Map<DOMDataTreeIdentifier, ChildShardContext> childShards) {
         super(dataTree, rootPath, childShards);
         notificationManager = QueuedNotificationManager.create(executor, (listener, notifications) -> {
-            // FIXME: we are not checking for listener being closed
-            listener.getInstance().onDataTreeChanged(notifications);
+            if (!listener.isClosed()) {
+                listener.getInstance().onDataTreeChanged(notifications);
+            }
         }, maxQueueSize, "DataTreeChangeListenerQueueMgr");
     }