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

[do-not-reply at jboss.org]

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" +