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 | 6 |
1 files changed, 3 insertions, 3 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 5a9cd39c5b4..7a39005cd48 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 @@ -28,7 +28,7 @@ public class SharedDestinationSession extends AbstractResource implements Messag SharedDestinationSession(SharedMessageBus mbus, DestinationSessionParams params) { this.msgHandler.set(params.getMessageHandler()); - this.session = mbus.messageBus().createDestinationSession(params.setMessageHandler(this)); + this.session = mbus.messageBus().createDetachedDestinationSession(params.setMessageHandler(this)); this.mbusReference = mbus.refer(); } @@ -77,8 +77,8 @@ public class SharedDestinationSession extends AbstractResource implements Messag } @Override - public void close() { - session.destroy(); + public void connect() { + session.connect(); } @Override |