This is an automated email from the ASF dual-hosted git repository.

cshannon pushed a commit to branch 6.1.x.AMF.x
in repository https://gitbox.apache.org/repos/asf/activemq.git

commit 279e4ad7b37896629446ebbb8a548135814ec7a7
Author: Christopher L. Shannon <[email protected]>
AuthorDate: Wed Sep 4 15:33:55 2024 -0400

    AMQ-8398 - Fix Stomp to Stomp Unicode UTF-8 test
    
    The connection receive was out of order and causing failures in some of
    the Stomp tests like StompNIOSSL
    
    (cherry picked from commit f5fb6c91b2f302459ab13b247630d4869ed8ce75)
---
 .../src/test/java/org/apache/activemq/transport/stomp/StompTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
 
b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
index 9e3b340325..9c82261e32 100644
--- 
a/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
+++ 
b/activemq-stomp/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
@@ -281,13 +281,13 @@ public class StompTest extends StompTestSupport {
 
         String frame = "CONNECT\n" + "login:system\n" + "passcode:manager\n\n" 
+ Stomp.NULL;
         stompConnection.sendFrame(frame);
+        frame = stompConnection.receiveFrame();
+        assertTrue(frame.startsWith("CONNECTED"));
 
         // publish message with string that requires 4-byte UTF-8 encoding
         frame = "SEND\n" + "destination:/queue/" + getQueueName() + "\n\n" + 
body + Stomp.NULL;
         stompConnection.sendFrame(frame);
 
-        frame = stompConnection.receiveFrame();
-        assertTrue(frame.startsWith("CONNECTED"));
         frame = "SUBSCRIBE\n" + "destination:/queue/" + getQueueName() + "\n" 
+ "ack:auto\n\n" + Stomp.NULL;
         stompConnection.sendFrame(frame);
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact


Reply via email to