diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-08 09:12:29 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-08 09:12:29 +0200 |
| commit | 08bf831e7d137f82de709a90f9704741e9f0641d (patch) | |
| tree | c0aa0b3dd8a02a5c303f22ca17cb5b7e587b9157 /container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java | |
| parent | 1f972c8c1fdf2419cd4b58fb5c84f3c313d46019 (diff) | |
Use refer(context) for mbus too.
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java')
| -rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java index 5f1963cffe6..e7b1fc3e71d 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java @@ -44,7 +44,7 @@ public final class MbusServer extends AbstractResource implements ServerProvider this.session = session; uri = URI.create("mbus://localhost/" + session.name()); session.setMessageHandler(this); - sessionReference = session.refer(); + sessionReference = session.refer(this); } @Override |