Make unit tests work when java dispatching is used by default

1 files changed, 7 insertions, 3 deletions

diff --git a/container-search/src/main/java/com/yahoo/fs4/mplex/FS4Channel.java b/container-search/src/main/java/com/yahoo/fs4/mplex/FS4Channel.java
index f40550f1f70..a4b61803285 100644
--- a/container-search/src/main/java/com/yahoo/fs4/mplex/FS4Channel.java
+++ b/container-search/src/main/java/com/yahoo/fs4/mplex/FS4Channel.java
@@ -199,9 +199,7 @@ public class FS4Channel {
         throws InterruptedException, InvalidChannelException
     {
         ensureValidQ().put(packet);
-        if(monitor != null) {
-            monitor.responseAvailable(this);
-        }
+        notifyMonitor();
     }
 
     /**
@@ -249,4 +247,10 @@ public class FS4Channel {
     public void setResponseMonitor(ResponseMonitor<FS4Channel> monitor) {
         this.monitor = monitor;
     }
+
+    protected void notifyMonitor() {
+        if(monitor != null) {
+            monitor.responseAvailable(this);
+        }
+    }
 }