svn commit: r1220724 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java

[gtully]

Author: gtully
Date: Mon Dec 19 12:54:38 2011
New Revision: 1220724

URL: http://svn.apache.org/viewvc?rev=1220724&view=rev
Log:
get a recept on send to ensure message gets there

Modified:
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?rev=1220724&r1=1220723&r2=1220724&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
 Mon Dec 19 12:54:38 2011
@@ -1798,9 +1798,15 @@ public class StompTest extends Combinati
         // Send a Message with the ReplyTo value set.
         HashMap<String, String> properties = new HashMap<String, String>();
         properties.put(Stomp.Headers.Send.REPLY_TO, tempDest);
+        properties.put(Stomp.Headers.RECEIPT_REQUESTED, "send-1");
         LOG.info(String.format("Sending request message: SEND with %s=%s", 
Stomp.Headers.Send.REPLY_TO, tempDest));
         stompConnection.send(dest, "REQUEST", null, properties);
 
+        frame = stompConnection.receiveFrame();
+        assertTrue("Receipt Frame: " + frame, 
frame.trim().startsWith("RECEIPT"));
+        assertTrue("Receipt contains correct receipt-id " + frame, 
frame.indexOf(Stomp.Headers.Response.RECEIPT_ID) >= 0);
+
+
         // The subscription should receive a response with the ReplyTo 
property set.
         StompFrame received = responder.receive();
         assertNotNull(received);