Author: jmesnil
Date: 2010-01-28 10:16:36 -0500 (Thu, 28 Jan 2010)
New Revision: 8857
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 14:36:24
UTC (rev 8856)
+++ trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java 2010-01-28 15:16:36
UTC (rev 8857)
@@ -1098,16 +1098,20 @@
frame =
"SUBSCRIBE\n" +
"destination:/topic/" + getTopicName() + "\n"
+
+ "receipt: 12\n" +
"\n\n" +
Stomp.NULL;
sendFrame(frame);
+ // wait for SUBSCRIBE's receipt
+ frame = receiveFrame(10000);
+ Assert.assertTrue(frame.startsWith("RECEIPT"));
sendMessage(getName(), topic);
frame = receiveFrame(10000);
Assert.assertTrue(frame.startsWith("MESSAGE"));
Assert.assertTrue(frame.indexOf("destination:") > 0);
- Assert.assertTrue(frame.indexOf(getTopicName()) > 0);
+ Assert.assertTrue(frame.indexOf(getName()) > 0);
frame =
"UNSUBSCRIBE\n" +