diff options
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java')
| -rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java index c4abe963d89..e0ab9dbff4f 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java @@ -29,7 +29,7 @@ public class SharedDestinationSession extends AbstractResource implements Messag SharedDestinationSession(SharedMessageBus mbus, DestinationSessionParams params) { this.msgHandler.set(params.getMessageHandler()); this.session = mbus.messageBus().createDetachedDestinationSession(params.setMessageHandler(this)); - this.mbusReference = mbus.refer(); + this.mbusReference = mbus.refer(this); } public DestinationSession session() { |