summaryrefslogtreecommitdiffstats
path: root/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedDestinationSession.java
diff options
context:
space:
mode:
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.java6
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