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=d997af59126833190b26696e752dfcc7061fe352;hb=c61d22e4dc73fdaba09aa8c0b189ea7459679e03;hp=52aa8d029066b3093a90300f6bb078886b2b3d7b;hpb=9d02282775e0464dd2b1e3e1c14bf02729f18ee9;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 52aa8d0290..d997af5912 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,14 +21,20 @@ 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
import com.google.common.collect.Multimaps
-
-class NotificationBrokerImpl implements NotificationProviderService, AutoCloseable {
+import org.opendaylight.controller.sal.binding.codegen.impl.SingletonHolder
import com.google.common.collect.Multimaps
+import org.opendaylight.yangtools.concepts.util.ListenerRegistry
+import org.opendaylight.controller.sal.binding.api.NotificationProviderService.NotificationInterestListener
 
+class NotificationBrokerImpl implements NotificationProviderService, AutoCloseable {
+    
+    val ListenerRegistry<NotificationInterestListener> interestListeners = ListenerRegistry.create;
+    
     val Multimap<Class<? extends Notification>, NotificationListener<?>> listeners;
 
     @Property
     var ExecutorService executor;
+    
+    val logger = LoggerFactory.getLogger(NotificationBrokerImpl)
 
     new() {
         listeners = Multimaps.synchronizedSetMultimap(HashMultimap.create())
@@ -101,14 +107,26 @@ class NotificationBrokerImpl implements NotificationProviderService, AutoCloseab
         NotificationListener<T> listener) {
         val reg = new GenericNotificationRegistration<T>(notificationType, listener, this);
         listeners.put(notificationType, listener);
+        announceNotificationSubscription(notificationType);
         return reg;
     }
+    
+    def announceNotificationSubscription(Class<? extends Notification> notification) {
+        for (listener : interestListeners) {
+            try {
+                listener.instance.onNotificationSubscribtion(notification);
+            } catch (Exception e) {
+                logger.error("", e.message)
+            }
+        }
+    }
 
     override registerNotificationListener(
         org.opendaylight.yangtools.yang.binding.NotificationListener listener) {
         val invoker = SingletonHolder.INVOKER_FACTORY.invokerFor(listener);
         for (notifyType : invoker.supportedNotifications) {
             listeners.put(notifyType, invoker.invocationProxy)
+            announceNotificationSubscription(notifyType)
         }
         val registration = new GeneratedListenerRegistration(listener, invoker,this);
         return registration as Registration<org.opendaylight.yangtools.yang.binding.NotificationListener>;
@@ -128,6 +146,14 @@ class NotificationBrokerImpl implements NotificationProviderService, AutoCloseab
         //FIXME: implement properly.
     }
     
+    override registerInterestListener(NotificationInterestListener interestListener) {
+        val registration = interestListeners.register(interestListener);
+        
+        for(notification : listeners.keySet) {
+            interestListener.onNotificationSubscribtion(notification);
+        }
+        return registration
+    }
 }
 
 class GenericNotificationRegistration<T extends Notification> extends AbstractObjectRegistration<NotificationListener<T>> implements ListenerRegistration<NotificationListener<T>> {