[hornetq-commits] JBoss hornetq SVN: r8853 - trunk/tests/src/org/hornetq/tests/integration/stomp.

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Jan 28 05:42:52 EST 2010


Author: jmesnil
Date: 2010-01-28 05:42:51 -0500 (Thu, 28 Jan 2010)
New Revision: 8853

Modified:
   trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-129: Implement STOMP v1.0

* test fixes

Modified: trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java	2010-01-28 09:52:47 UTC (rev 8852)
+++ trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java	2010-01-28 10:42:51 UTC (rev 8853)
@@ -754,10 +754,15 @@
 
         frame =
                 "SUBSCRIBE\n" +
-                        "destination:/queue/" + getQueueName() + "\n\n" +
+                        "destination:/queue/" + getQueueName() + "\n" +
+                        "receipt: 1234\n\n" +
                         Stomp.NULL;
 
         sendFrame(frame);
+        // wait for SUBSCRIBE's receipt
+        frame = receiveFrame(10000);
+        Assert.assertTrue(frame.startsWith("RECEIPT"));
+
         sendMessage("shouldBeNextMessage");
 
         frame = receiveFrame(10000);
@@ -1109,7 +1114,7 @@
                   "\n\n" +
                   Stomp.NULL;
        sendFrame(frame);
-       // wait for UNSUBSCRIPE's receipt
+       // wait for UNSUBSCRIBE's receipt
        frame = receiveFrame(10000);
        Assert.assertTrue(frame.startsWith("RECEIPT"));
   



More information about the hornetq-commits mailing list