commit f7f52ccc7a7e7b0e95a760a4b63bc4429316b4e8
author Jean-Baptiste Onofré <jbonofre@apache.org> Wed Aug 04 08:23:59 2021 +0200
committer GitHub <noreply@github.com> Wed Aug 04 08:23:59 2021 +0200
tree 688f79e9e827d0a016862b8dfeac90a7313e81c9
parent 0348938952ccb43ccb3453c2e932124f39decd74
parent ceaeaa986b4f9a233fe7b24f0e7b3b5c2dcfa9ec

Merge pull request #695 from jbonofre/AMQ-8252

[AMQ-8252] Doesn't display warn stack trace for stomp (regression compared to 5.15.x)

activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java

diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
index eec0aea..44b7968 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
@@ -247,7 +247,12 @@
     }
 
     private boolean suppressed(IOException e) {
-        return !connector.isWarnOnRemoteClose() && ((e instanceof SocketException && e.getMessage().indexOf("reset") != -1) || e instanceof EOFException);
+        return (isStomp() || !connector.isWarnOnRemoteClose()) && ((e instanceof SocketException && e.getMessage().indexOf("reset") != -1) || e instanceof EOFException);
+    }
+
+    private boolean isStomp() {
+        URI uri = connector.getUri();
+        return uri != null && uri.getScheme() != null && uri.getScheme().indexOf("stomp") != -1;
     }
 
     /**