diff options
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.java | 8 |
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 |