svn commit: r1330940 - /activemq/activemq-apollo/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/StompTest.scala

[ch...@apache.org]

Author: chirino
Date: Thu Apr 26 16:37:59 2012
New Revision: 1330940

URL: http://svn.apache.org/viewvc?rev=1330940&view=rev
Log:
Add a little sleep to make the test more reliable.

Modified:
    activemq/activemq-apollo/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/StompTest.scala

Modified: activemq/activemq-apollo/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/StompTest.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/StompTest.scala?rev=1330940&r1=1330939&r2=1330940&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/StompTest.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/StompTest.scala Thu Apr 26 16:37:59 2012
@@ -543,7 +543,8 @@ class StompPersistentQueueTest extends S
     var counter = 0
     for( i <- 0 until 100 ) {
       connect("1.1")
-      subscribe("1", "/queue/BIGQUEUE", "client", false, "", false)
+      // Use exclusive to avoid 2 concurrent subs (disconnect is async..)
+      subscribe("1", "/queue/BIGQUEUE", "client", false, "exclusive:true\n", false)
       for( j <- 0 until 100 ) {
         assert_received("message #"+counter)(true)
         counter+=1
@@ -554,6 +555,7 @@ class StompPersistentQueueTest extends S
         "\n")
       wait_for_receipt("disco", client, true)
       client.close
+      Thread.sleep(200)
     }
 
     connect("1.1")