- Remove dead code.

- Use atomic boolean destroyed as signal.

1 files changed, 1 insertions, 15 deletions

diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
index 0e8703b8a58..8b8068c0437 100644
--- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java
@@ -165,23 +165,9 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked
         return Result.ACCEPTED;
     }
 
-    public void blockedSendLoop()  {
-        while (!closed) {
-            sendBlockedMessages();
-            expireStalledBlockedMessages();
-            try {
-                Thread.sleep(10);
-            } catch (InterruptedException e) {
-                return;
-            }
-        }
-        sendBlockedMessages();
-        expireStalledBlockedMessages();
-    }
-
     @Override
     public boolean trySend() {
-        if (closed) return false;
+        if (destroyed.get()) return false;
         sendBlockedMessages();
         expireStalledBlockedMessages();
         return true;