Switch to using SseEventSink

[netconf.git] / restconf / restconf-nb-rfc8040 / src / main / java / org / opendaylight / restconf / nb / rfc8040 / streams / listeners / ListenersBroker.java

diff --git a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java
index d1dadcf22e7eea547db73b0baf0b0deb65f09ef3..b27502ac28be36b916e27acdbd6cc2be6b7e1f48 100644 (file)
--- a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java
+++ b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/ListenersBroker.java
@@ -49,6 +49,7 @@ public final class ListenersBroker {
      *
      * @return Reusable instance of {@link ListenersBroker}.
      */
+    // FIXME: remove this global singleton
     public static synchronized ListenersBroker getInstance() {
         if (listenersBroker == null) {
             listenersBroker = new ListenersBroker();
@@ -303,7 +304,7 @@ public final class ListenersBroker {
     }
 
     @SuppressWarnings({"checkstyle:IllegalCatch"})
-    private void removeAndCloseNotificationListenerTemplate(NotificationListenerAdapter listener) {
+    private void removeAndCloseNotificationListenerTemplate(final NotificationListenerAdapter listener) {
         try {
             requireNonNull(listener).close();
             if (notificationListeners.inverse().remove(listener) == null) {