X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fbinding%2Fimpl%2FNotificationBrokerImpl.xtend;h=a3c8c5f232b0b6e7daae0350880eca7e790985a5;hb=8ccb61090ae30c7ea750b606034016c248d90f80;hp=e8b3850b77b665113b3bac0d9e33c8029cc592fc;hpb=9468a50a8108ba5834e57b318bad7778cb31df12;p=controller.git

diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/NotificationBrokerImpl.xtend b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/NotificationBrokerImpl.xtend
index e8b3850b77..a3c8c5f232 100644
--- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/NotificationBrokerImpl.xtend
+++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/NotificationBrokerImpl.xtend
@@ -21,6 +21,7 @@ import org.opendaylight.yangtools.concepts.ListenerRegistration
 import org.opendaylight.yangtools.concepts.Registration
 import org.opendaylight.yangtools.yang.binding.Notification
 import org.slf4j.LoggerFactory
+import org.opendaylight.controller.sal.binding.codegen.impl.SingletonHolder
 
 class NotificationBrokerImpl implements NotificationProviderService, AutoCloseable {
 
@@ -29,6 +30,11 @@ class NotificationBrokerImpl implements NotificationProviderService, AutoCloseab
     @Property
     var ExecutorService executor;
 
+    new() {
+        listeners = HashMultimap.create()
+    }
+
+    @Deprecated
     new(ExecutorService executor) {
         listeners = HashMultimap.create()
         this.executor = executor;
@@ -100,7 +106,7 @@ class NotificationBrokerImpl implements NotificationProviderService, AutoCloseab
 
     override registerNotificationListener(
         org.opendaylight.yangtools.yang.binding.NotificationListener listener) {
-        val invoker = BindingAwareBrokerImpl.generator.invokerFactory.invokerFor(listener);
+        val invoker = SingletonHolder.INVOKER_FACTORY.invokerFor(listener);
         for (notifyType : invoker.supportedNotifications) {
             listeners.put(notifyType, invoker.invocationProxy)
         }
@@ -169,14 +175,24 @@ class NotifyTask implements Callable<Object> {
 
     private static val log = LoggerFactory.getLogger(NotifyTask);
 
+    @SuppressWarnings("rawtypes")
     val NotificationListener listener;
     val Notification notification;
 
     override call() {
+        //Only logging the complete notification in debug mode
         try {
-            log.info("Delivering notification {} to {}",notification,listener);
+            if(log.isDebugEnabled){
+                log.debug("Delivering notification {} to {}",notification,listener);
+            } else {
+                log.trace("Delivering notification {} to {}",notification.class.name,listener);
+            }
             listener.onNotification(notification);
-            log.info("Notification delivered {} to {}",notification,listener);
+            if(log.isDebugEnabled){
+                log.debug("Notification delivered {} to {}",notification,listener);
+            } else {
+                log.trace("Notification delivered {} to {}",notification.class.name,listener);
+            }
         } catch (Exception e) {
             log.error("Unhandled exception thrown by listener: {}", listener, e);
         }