diff options
Diffstat (limited to 'container-messagebus/src/main/java/com/yahoo')
-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; } |