diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-16 14:33:51 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-16 14:33:51 +0100 |
commit | 7ad43aae85e1dcbdc9ae814d9babe18e02012797 (patch) | |
tree | 218179dab5b5a0d5eab317fca668b8a72c13ed4c /messagebus | |
parent | c50b98dd4d410849733bbc8f947c625c805d1442 (diff) |
- Remove dead code.
- Use atomic boolean destroyed as signal.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 16 |
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; |