diff options
author | Olli Virtanen <olli.virtanen@oath.com> | 2019-01-04 13:05:45 +0100 |
---|---|---|
committer | Olli Virtanen <olli.virtanen@oath.com> | 2019-01-04 13:05:45 +0100 |
commit | 2ceaf743502d24aed4ecfac26d26518de7d9a803 (patch) | |
tree | 1cf657d4b4373be0e62d8c7e5a3b9914a13a302a /container-search/src/main/java/com/yahoo/fs4 | |
parent | a51bf4432797d9db5131a27b0b1136d0541f8587 (diff) |
Make unit tests work when java dispatching is used by default
Diffstat (limited to 'container-search/src/main/java/com/yahoo/fs4')
-rw-r--r-- | container-search/src/main/java/com/yahoo/fs4/mplex/FS4Channel.java | 10 |
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); + } + } } |