[hornetq-commits] JBoss hornetq SVN: r8853 - trunk/tests/src/org/hornetq/tests/integration/stomp.
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"));