summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2021-06-28 16:40:51 +0200
committerJon Bratseth <bratseth@gmail.com>2021-06-28 16:40:51 +0200
commit55bbae63665929d4b2e11af9a40392df2e409413 (patch)
tree65a671c0e756e32f3470b9fd1e9d3b6487a74658 /messagebus
parent294127fe37e66cc19c85e9e784ca52299fff3dcc (diff)
No functional changes
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/Sequencer.java1
-rw-r--r--messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java7
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);