X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2Fimpl%2FNotificationRouterImpl.java;h=763407f23a671476c7f47a9c8f7e3d63e0b2b128;hb=ce2938e5616a170ca2fb2f5b478b3b2ceff832a1;hp=6d7b600dbcb3a4b68377cdec27a3314e24df6812;hpb=3a9f0addbcd1d3504ffaae935b64d3173b74f426;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/NotificationRouterImpl.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/NotificationRouterImpl.java index 6d7b600dbc..763407f23a 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/NotificationRouterImpl.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/impl/NotificationRouterImpl.java @@ -34,16 +34,17 @@ import org.slf4j.LoggerFactory; import com.google.common.collect.HashMultimap; import com.google.common.collect.ImmutableSet; import com.google.common.collect.Multimap; +import com.google.common.collect.Multimaps; public class NotificationRouterImpl implements NotificationRouter { private static Logger log = LoggerFactory.getLogger(NotificationRouterImpl.class); - private Multimap> listeners = HashMultimap.create(); + private Multimap> listeners = Multimaps.synchronizedSetMultimap(HashMultimap.>create()); private void sendNotification(CompositeNode notification) { QName type = notification.getNodeType(); Collection> toNotify = listeners.get(type); - log.info("Publishing notification " + type); + log.trace("Publishing notification " + type); if (toNotify == null) { // No listeners were registered - returns.