summaryrefslogtreecommitdiffstats
path: root/container-messagebus
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2023-11-30 09:47:10 +0100
committerjonmv <venstad@gmail.com>2023-11-30 09:47:10 +0100
commitd3937b5d44a1a13dd3b895029c7dcbfe32d3d7e1 (patch)
tree0c1c3d9d1ceabd9c0ae67c303d40ede22d76246d /container-messagebus
parentaa207732992038ae65d73a04832ac8a3753b73a9 (diff)
Non-funcitonal changes
Diffstat (limited to 'container-messagebus')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java2
-rw-r--r--container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java1
2 files changed, 2 insertions, 1 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java
index dee4e3dcfbb..d570747ad11 100644
--- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java
+++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java
@@ -90,7 +90,7 @@ public final class MbusClient extends AbstractResource implements ClientProvider
@Override
public void handleReply(final Reply reply) {
reply.getTrace().trace(6, "Reply received by MbusClient.");
- final ResponseHandler handler = (ResponseHandler)reply.getContext();
+ ResponseHandler handler = (ResponseHandler) reply.getContext();
reply.popHandler(); // restore user context
try {
handler.handleResponse(new MbusResponse(StatusCodes.fromMbusReply(reply), reply))
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
index 1b3a9afff7b..2283f703463 100644
--- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
+++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
@@ -109,4 +109,5 @@ public class SharedIntermediateSession extends AbstractResource
session.destroy();
mbusReference.close();
}
+
}