aboutsummaryrefslogtreecommitdiffstats
path: root/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-08-23 10:14:03 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-08-23 10:14:03 +0200
commit26d36def2b74166bda5000660ad8a9467f57e728 (patch)
tree59ba2afaaecdf612c1aed82aef153eb3b9f6ead6 /container-messagebus/src/main/java/com/yahoo/messagebus/jdisc
parent43402b23dc74fe6550d231b26e8c50327e1971f9 (diff)
Let server session.connect() conncet to net, and use newest destination
No practical changes, but less API misuse. @bjorncs please review.
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/jdisc')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java
index a2131f22dc4..67badddddd2 100644
--- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java
+++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java
@@ -43,6 +43,7 @@ public final class MbusServer extends AbstractResource implements ServerProvider
@Override
public void start() {
log.log(Level.FINE, "Starting message bus server.");
+ session.connect();
running.set(true);
}
@@ -50,7 +51,6 @@ public final class MbusServer extends AbstractResource implements ServerProvider
public void close() {
log.log(Level.FINE, "Closing message bus server.");
running.set(false);
- session.close();
}
@Override