diff options
author | jonmv <venstad@gmail.com> | 2023-11-30 09:47:10 +0100 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-11-30 09:47:10 +0100 |
commit | d3937b5d44a1a13dd3b895029c7dcbfe32d3d7e1 (patch) | |
tree | 0c1c3d9d1ceabd9c0ae67c303d40ede22d76246d /container-messagebus | |
parent | aa207732992038ae65d73a04832ac8a3753b73a9 (diff) |
Non-funcitonal changes
Diffstat (limited to 'container-messagebus')
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java | 2 | ||||
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java | 1 |
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(); } + } |