You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2020/06/17 17:52:56 UTC

[activemq-artemis] branch master updated: ARTEMIS-2807 avoid notifications on critical IO error

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new 79e0577  ARTEMIS-2807 avoid notifications on critical IO error
     new 7f3ee5e  This closes #3188
79e0577 is described below

commit 79e05774b873d63a87ec73ce0c2de2040a9b63dd
Author: Justin Bertram <jb...@apache.org>
AuthorDate: Tue Jun 16 15:11:44 2020 -0500

    ARTEMIS-2807 avoid notifications on critical IO error
---
 .../apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java | 5 +++++
 1 file changed, 5 insertions(+)

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 d40a50b..9910091 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;