diff options
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedSourceSession.java')
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedSourceSession.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedSourceSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedSourceSession.java index a185922545e..016fb8975a7 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedSourceSession.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedSourceSession.java @@ -27,7 +27,7 @@ public class SharedSourceSession extends AbstractResource implements ClientSessi throw new IllegalArgumentException("Reply handler must be null."); } this.session = mbus.messageBus().createSourceSession(params.setReplyHandler(this)); - this.mbusReference = mbus.refer(); + this.mbusReference = mbus.refer(this); } public SourceSession session() { |