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 eec0aeacf7..44b7968113 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 @@ public class TransportConnection implements Connection, Task, CommandVisitor { } 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; } /**