diff options
author | Jon Bratseth <bratseth@gmail.com> | 2021-06-28 16:40:51 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2021-06-28 16:40:51 +0200 |
commit | 55bbae63665929d4b2e11af9a40392df2e409413 (patch) | |
tree | 65a671c0e756e32f3470b9fd1e9d3b6487a74658 /messagebus | |
parent | 294127fe37e66cc19c85e9e784ca52299fff3dcc (diff) |
No functional changes
Diffstat (limited to 'messagebus')
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java | 1 | ||||
-rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 7 |
2 files changed, 4 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java index 39fc9aa8314..fcef11b2e74 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java @@ -152,4 +152,5 @@ public class Sequencer implements MessageHandler, ReplyHandler { ReplyHandler handler = reply.popHandler(); handler.handleReply(reply); } + } diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java index 204bf2f7906..248cbdca7a0 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -137,8 +137,7 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked private Result sendInternal(Message message) { synchronized (lock) { if (closed) { - return new Result(ErrorCode.SEND_QUEUE_CLOSED, - "Source session is closed."); + return new Result(ErrorCode.SEND_QUEUE_CLOSED, "Source session is closed."); } if (throttlePolicy != null && ! throttlePolicy.canSend(message, pendingCount)) { return new Result(ErrorCode.SEND_QUEUE_FULL, @@ -152,8 +151,8 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked } if (message.getTrace().shouldTrace(TraceLevel.COMPONENT)) { message.getTrace().trace(TraceLevel.COMPONENT, - "Source session accepted a " + message.getApproxSize() + " byte message. " + - pendingCount + " message(s) now pending."); + "Source session accepted a " + message.getApproxSize() + " byte message. " + + pendingCount + " message(s) now pending."); } message.pushHandler(this); sequencer.handleMessage(message); |