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;