summaryrefslogtreecommitdiffstats
path: root/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-01-07 19:48:27 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-01-07 19:48:27 +0100
commitf481487c49e3ffd5119f9d5b0df53345e8083f33 (patch)
treeeff248d7ae5acc2bd63590b6cfd21be8271b9e1d /container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java
parent773b475bd018104200391de380e9f570454faa19 (diff)
After we close a MBusServer we are not busy, retrying will not make life better.
Shutdown is a better error code.
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java')
-rw-r--r--container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java4
1 files changed, 1 insertions, 3 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 084a5f82268..9a8dda246a0 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
@@ -75,9 +75,7 @@ public final class MbusServer extends AbstractResource implements ServerProvider
return;
}
if (state == State.STOPPED) {
- // We might need to detect requests originating from the same JVM, as they need to fail fast
- // as they are holding references to the container preventing proper shutdown.
- dispatchErrorReply(msg, ErrorCode.SESSION_BUSY, "MBusServer has been closed.");
+ dispatchErrorReply(msg, ErrorCode.NETWORK_SHUTDOWN, "MBusServer has been closed.");
return;
}
if (msg.getTrace().shouldTrace(6)) {