summaryrefslogtreecommitdiffstats
path: root/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
index 64cc1aaf510..cb35a0a42f1 100644
--- a/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
+++ b/container-messagebus/src/main/java/com/yahoo/messagebus/shared/SharedIntermediateSession.java
@@ -35,8 +35,8 @@ public class SharedIntermediateSession extends AbstractResource
throw new IllegalArgumentException("Reply handler must be null.");
}
this.msgHandler.set(params.getMessageHandler());
- this.session = mbus.messageBus().createIntermediateSession(params.setReplyHandler(this)
- .setMessageHandler(this));
+ this.session = mbus.messageBus().createDetachedIntermediateSession(params.setReplyHandler(this)
+ .setMessageHandler(this));
this.mbusReference = mbus.refer();
}
@@ -96,8 +96,8 @@ public class SharedIntermediateSession extends AbstractResource
}
@Override
- public void close() {
- session.destroy();
+ public void connect() {
+ session.connect();
}
@Override