diff --git a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java index 07a85b1207..28d0de4813 100644 --- a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java +++ b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java @@ -286,11 +286,9 @@ public final class StompConnection implements RemotingConnection { return; } - if (me != null) { - StompFrame frame = frameHandler.createStompFrame(Stomp.Responses.ERROR); - frame.addHeader(Stomp.Headers.Error.MESSAGE, me.getMessage()); - sendFrame(frame); - } + StompFrame frame = frameHandler.createStompFrame(Stomp.Responses.ERROR); + frame.addHeader(Stomp.Headers.Error.MESSAGE, me.getMessage()); + sendFrame(frame); destroyed = true; }