diff options
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java')
| -rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusClient.java | 2 |
1 files changed, 1 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 85eb703d4cd..7fa294422d6 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 @@ -41,7 +41,7 @@ public final class MbusClient extends AbstractResource implements ClientProvider @Inject public MbusClient(ClientSession session) { this.session = session; - this.sessionReference = session.refer(); + this.sessionReference = session.refer(this); thread = new Thread(new SenderTask(), "mbus-client-" + threadId.getAndIncrement()); } |