From ae82a773950ead2c4113652cc3a3a1df62a11934 Mon Sep 17 00:00:00 2001
From: Henning Baldersheim <balder@yahoo-inc.com>
Date: Sat, 13 Apr 2019 00:07:30 +0200
Subject: Revert "Revert "Reply in own thread""

---
 .../main/java/com/yahoo/messagebus/Messenger.java  | 31 ++++------------------
 1 file changed, 5 insertions(+), 26 deletions(-)

(limited to 'messagebus')

diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java
index 2cb2f0967e5..7211e4cead0 100755
--- a/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/Messenger.java
@@ -78,7 +78,11 @@ public class Messenger implements Runnable {
      * @param handler The handler to return to.
      */
     public void deliverReply(final Reply reply, final ReplyHandler handler) {
-        enqueue(new ReplyTask(reply, handler));
+        if (destroyed.get()) {
+            reply.discard();
+        } else {
+            handler.handleReply(reply);
+        }
     }
 
     /**
@@ -208,31 +212,6 @@ public class Messenger implements Runnable {
         void destroy();
     }
 
-    private static class ReplyTask implements Task {
-
-        final ReplyHandler handler;
-        Reply reply;
-
-        ReplyTask(final Reply reply, final ReplyHandler handler) {
-            this.reply = reply;
-            this.handler = handler;
-        }
-
-        @Override
-        public void run() {
-            final Reply reply = this.reply;
-            this.reply = null;
-            handler.handleReply(reply);
-        }
-
-        @Override
-        public void destroy() {
-            if (reply != null) {
-                reply.discard();
-            }
-        }
-    }
-
     private static class SyncTask implements Task {
 
         final CountDownLatch latch = new CountDownLatch(1);
-- 
cgit v1.2.3