diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java index d40a50b7cf..9910091cd7 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java @@ -1071,6 +1071,11 @@ public class ActiveMQServerImpl implements ActiveMQServer { } state = SERVER_STATE.STOPPING; + if (criticalIOError) { + // notifications trigger disk IO so we don't want to send any on a critical IO error + managementService.enableNotifications(false); + } + if (fileStoreMonitor != null) { fileStoreMonitor.stop(); fileStoreMonitor = null;