diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-12 17:38:00 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-12 17:38:00 +0200 |
commit | 7f83b13ecb8ba0721c591f8bb6b82512021ad29c (patch) | |
tree | 0a5c0c867676001f0af6604a9d826bd9eecf75cd /messagebus | |
parent | bf9e3dd858e73e2670b0d99a33ac7d9e421b550b (diff) |
Simplify with lambda.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java index 2a4a123a60b..920d285d200 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -4,7 +4,6 @@ package com.yahoo.messagebus; import com.yahoo.messagebus.routing.Route; import com.yahoo.messagebus.routing.RoutingTable; -import java.util.Iterator; import java.util.LinkedList; import java.util.Queue; import java.util.concurrent.CountDownLatch; @@ -209,7 +208,7 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked } } - Reply createSendTimedoutReply(Message msg, Error error) { + private Reply createSendTimedoutReply(Message msg, Error error) { Reply reply = new EmptyReply(); reply.setMessage(msg); reply.addError(error); @@ -246,12 +245,7 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked private void expireStalledBlockedMessages() { synchronized (lock) { - Iterator<BlockedMessage> each = blockedQ.iterator(); - while (each.hasNext()) { - if (each.next().notifyIfExpired()) { - each.remove(); - } - } + blockedQ.removeIf(BlockedMessage::notifyIfExpired); } } |