Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

get a recept on send to ensure message gets there 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1220724 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2011-12-19 12:54:38 +00:00
parent 7da61d992f
commit 882c5539d1
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
View File

@ -1798,9 +1798,15 @@ public class StompTest extends CombinationTestSupport {
// Send a Message with the ReplyTo value set. // Send a Message with the ReplyTo value set.
HashMap<String, String> properties = new HashMap<String, String>(); HashMap<String, String> properties = new HashMap<String, String>();
properties.put(Stomp.Headers.Send.REPLY_TO, tempDest); 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)); LOG.info(String.format("Sending request message: SEND with %s=%s", Stomp.Headers.Send.REPLY_TO, tempDest));
stompConnection.send(dest, "REQUEST", null, properties); 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. // The subscription should receive a response with the ReplyTo property set.
StompFrame received = responder.receive(); StompFrame received = responder.receive();
assertNotNull(received); assertNotNull(received);