aboutsummaryrefslogtreecommitdiffstats
path: root/container-messagebus
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2022-10-10 09:37:06 +0200
committerjonmv <venstad@gmail.com>2022-10-10 09:37:06 +0200
commitbf4cac21aaf3776667cfcb117a4b2f931c875675 (patch)
treeab07766c239bb023fe3b3b1b8fba4c60bcf2bacb /container-messagebus
parent240a62de8a9b3c93fb9f7031f5e204264d414817 (diff)
Start new mbus servers before stopping old ones
Diffstat (limited to 'container-messagebus')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java5
1 files changed, 5 insertions, 0 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 8f21cb227d8..3cf3b4bf8b0 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
@@ -60,6 +60,11 @@ public final class MbusServer extends AbstractResource implements ServerProvider
}
@Override
+ public boolean isMultiplexed() {
+ return true;
+ }
+
+ @Override
protected void destroy() {
log.log(Level.FINE, "Destroying message bus server.");
runState.set(State.STOPPED);