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

Give a little extra time for the Stomp frames to take effect. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1180059 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2011-10-07 14:43:53 +00:00
parent bfd1be561d
commit 216f74e003
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-core/src/test/java/org/apache/activemq/transport/stomp/Stomp11Test.java
View File

@ -23,6 +23,7 @@ import java.net.SocketTimeoutException;
import java.net.URI; import java.net.URI;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.concurrent.TimeUnit;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.MessageConsumer; import javax.jms.MessageConsumer;
@ -274,7 +275,7 @@ public class Stomp11Test extends CombinationTestSupport {
assertTrue(f.indexOf("session:") >= 0); assertTrue(f.indexOf("session:") >= 0);
LOG.debug("Broker sent: " + f); LOG.debug("Broker sent: " + f);
Thread.sleep(5000); Thread.sleep(TimeUnit.SECONDS.toMillis(10));
try { try {
String message = "SEND\n" + "destination:/queue/" + getQueueName() + "\n\n" + "Hello World" + Stomp.NULL; String message = "SEND\n" + "destination:/queue/" + getQueueName() + "\n\n" + "Hello World" + Stomp.NULL;
@ -372,7 +373,7 @@ public class Stomp11Test extends CombinationTestSupport {
"id:12345\n\n" + Stomp.NULL; "id:12345\n\n" + Stomp.NULL;
stompConnection.sendFrame(frame); stompConnection.sendFrame(frame);
Thread.sleep(2000); Thread.sleep(4000);
stompConnection.sendFrame(message); stompConnection.sendFrame(message);