diff options
author | jonmv <venstad@gmail.com> | 2023-11-30 09:49:39 +0100 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-11-30 09:49:39 +0100 |
commit | 7dde0ab9f6d19e25d55f1b1b4798f83b3ba6592d (patch) | |
tree | ae39de27a96e349c7da847af91ce9aea0c3c8276 /container-messagebus | |
parent | 31c7fe405206f4aa86ecd0f93309f26adf2e1205 (diff) |
Add some warnings for unexpected scenarios
Diffstat (limited to 'container-messagebus')
-rw-r--r-- | container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusServer.java | 3 |
1 files changed, 3 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 4c21489ded2..42fbec7711d 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 @@ -67,6 +67,8 @@ public final class MbusServer extends AbstractResource implements ServerProvider @Override protected void destroy() { log.log(Level.INFO, "Destroying message bus server: " + session.name()); + if (runState.get() == State.RUNNING) + log.log(Level.WARNING, "Message bus server destroyed before being disconnected: " + session.name()); runState.set(State.STOPPED); sessionReference.close(); } @@ -79,6 +81,7 @@ public final class MbusServer extends AbstractResource implements ServerProvider return; } if (state == State.STOPPED) { + log.log(Level.WARNING, "Message bus server received message after being stopped: " + session.name()); dispatchErrorReply(msg, ErrorCode.NETWORK_SHUTDOWN, "MBusServer has been closed."); return; } |