activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1220724 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
Date Mon, 19 Dec 2011 12:54:38 GMT
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);



Mime
View raw message