diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-06 22:08:04 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-06 22:08:04 +0100 |
commit | 1fda1d9542a55a25168816f59a0e82405d8b4ae6 (patch) | |
tree | 52bf98f7331b76cabcc09c9c602be80d9a180424 /messagebus | |
parent | 762a33c2f39db024965d3e7063ae2eb7da2ef8b5 (diff) |
Use lambda for thread and l -> L for long constants.
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java index 64d5f9843ee..3858a587fdf 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -16,7 +16,7 @@ import java.util.logging.Logger; * * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a> */ -public final class SourceSession implements ReplyHandler, Runnable { +public final class SourceSession implements ReplyHandler { private static Logger log = Logger.getLogger(SourceSession.class.getName()); private final AtomicBoolean destroyed = new AtomicBoolean(false); @@ -51,7 +51,7 @@ public final class SourceSession implements ReplyHandler, Runnable { replyHandler = params.getReplyHandler(); throttlePolicy = params.getThrottlePolicy(); timeout = params.getTimeout(); - blockedMessageSender = new Thread(this); + blockedMessageSender = new Thread(this::blockedSendLoop); blockedMessageSender.setDaemon(true); blockedMessageSender.start(); } @@ -137,7 +137,7 @@ public final class SourceSession implements ReplyHandler, Runnable { private Message updateTiming(Message msg) { msg.setTimeReceivedNow(); if (msg.getTimeRemaining() <= 0) { - msg.setTimeRemaining((long)(timeout) * 1000l); + msg.setTimeRemaining((long)(timeout) * 1000L); } return msg; } @@ -167,8 +167,7 @@ public final class SourceSession implements ReplyHandler, Runnable { return Result.ACCEPTED; } - @Override - public void run() { + public void blockedSendLoop() { while (!closed) { sendBlockedMessages(); expireStalledBlockedMessages(); |