diff --git a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java b/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java index 05a2c6a67b..e71210c13c 100644 --- a/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java +++ b/tests/artemis-test-support/src/main/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java @@ -106,7 +106,7 @@ public class StompClientConnectionV11 extends StompClientConnectionV10 { frame.addHeader(Stomp.Headers.RECEIPT_REQUESTED, uuid); try { - if (!transport.isConnected()) { + if (transport.isConnected()) { ClientStompFrame result = this.sendFrame(frame); if (result == null || (!Stomp.Responses.RECEIPT.equals(result.getCommand())) || (!uuid.equals(result.getHeader(Stomp.Headers.Response.RECEIPT_ID)))) { throw new IOException("Disconnect failed! " + result);