diff --git a/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java b/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java
index 4d713f6..81c6f6e 100644
--- a/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java
+++ b/protocols/netconf/ctl/src/main/java/org/onosproject/netconf/ctl/NetconfStreamThread.java
@@ -173,6 +173,7 @@
         abstract NetconfMessageState evaluateChar(char c);
     }
 
+    @Override
     public void run() {
         BufferedReader bufferReader = new BufferedReader(new InputStreamReader(in));
             try {
@@ -224,6 +225,7 @@
                                          netconfDeviceInfo, enableNotifications,
                                          getMsgId(deviceReply), deviceReply);
                                 if (enableNotifications) {
+                                    log.debug("dispatching to {} listeners", netconfDeviceEventListeners.size());
                                     final String finalDeviceReply = deviceReply;
                                     netconfDeviceEventListeners.forEach(
                                             listener -> listener.event(new NetconfDeviceOutputEvent(
@@ -259,16 +261,19 @@
         return Optional.empty();
     }
 
+    @Override
     public void addDeviceEventListener(NetconfDeviceOutputEventListener listener) {
         if (!netconfDeviceEventListeners.contains(listener)) {
             netconfDeviceEventListeners.add(listener);
         }
     }
 
+    @Override
     public void removeDeviceEventListener(NetconfDeviceOutputEventListener listener) {
         netconfDeviceEventListeners.remove(listener);
     }
 
+    @Override
     public void setEnableNotifications(boolean enableNotifications) {
         this.enableNotifications = enableNotifications;
     }