Turn ListenersBroker into a component

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

diff --git a/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/AbstractNotificationListenerAdaptor.java b/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/AbstractNotificationListenerAdaptor.java
index 7cab6107c5ebd4de689b347d7f6118addfc8d0e3..ab829cbf8bfe409e8f8f30694c83290ed263f06a 100644 (file)
--- a/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/AbstractNotificationListenerAdaptor.java
+++ b/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/nb/rfc8040/streams/listeners/AbstractNotificationListenerAdaptor.java
@@ -29,8 +29,9 @@ abstract class AbstractNotificationListenerAdaptor extends AbstractCommonSubscri
     private static final NotificationFormatterFactory JSON_FORMATTER_FACTORY =
         JSONNotificationFormatter.createFactory(JSONCodecFactorySupplier.RFC7951);
 
-    AbstractNotificationListenerAdaptor(final String streamName, final NotificationOutputType outputType) {
-        super(streamName, outputType, getFormatterFactory(outputType));
+    AbstractNotificationListenerAdaptor(final String streamName, final NotificationOutputType outputType,
+            final ListenersBroker listenersBroker) {
+        super(streamName, outputType, getFormatterFactory(outputType), listenersBroker);
     }
 
     private static NotificationFormatterFactory getFormatterFactory(final NotificationOutputType outputType) {
@@ -50,8 +51,7 @@ abstract class AbstractNotificationListenerAdaptor extends AbstractCommonSubscri
 
         final Optional<String> maybeOutput;
         try {
-            maybeOutput = formatter().eventData(effectiveModel(), notification, eventInstant, getLeafNodesOnly(),
-                isSkipNotificationData(), getChangedLeafNodesOnly());
+            maybeOutput = formatter().eventData(effectiveModel(), notification, eventInstant);
         } catch (Exception e) {
             LOG.error("Failed to process notification {}", notification, e);
             return;