You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2011/08/16 20:38:46 UTC
svn commit: r1158413 - /activemq/activemq-apollo/trunk/apollo-openwire/src/test/scala/org/apache/activemq/apollo/openwire/QueueTest.scala

Author: chirino
Date: Tue Aug 16 18:38:46 2011
New Revision: 1158413

URL: http://svn.apache.org/viewvc?rev=1158413&view=rev
Log:
Make the queue browser tests more robust by using a distinct queue for each.

Modified:
    activemq/activemq-apollo/trunk/apollo-openwire/src/test/scala/org/apache/activemq/apollo/openwire/QueueTest.scala

Modified: activemq/activemq-apollo/trunk/apollo-openwire/src/test/scala/org/apache/activemq/apollo/openwire/QueueTest.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-openwire/src/test/scala/org/apache/activemq/apollo/openwire/QueueTest.scala?rev=1158413&r1=1158412&r2=1158413&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-openwire/src/test/scala/org/apache/activemq/apollo/openwire/QueueTest.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-openwire/src/test/scala/org/apache/activemq/apollo/openwire/QueueTest.scala Tue Aug 16 18:38:46 2011
@@ -100,8 +100,8 @@ class QueueTest extends OpenwireTestSupp
 
     val session = default_connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
 
-    val producer = session.createProducer(queue("BROWSER.TEST"))
-    var consumer = session.createConsumer(queue("BROWSER.TEST"))
+    val producer = session.createProducer(queue("BROWSER.TEST.RB"))
+    var consumer = session.createConsumer(queue("BROWSER.TEST.RB"))
 
     val outbound = List(session.createTextMessage("First Message"),
                         session.createTextMessage("Second Message"),
@@ -119,7 +119,7 @@ class QueueTest extends OpenwireTestSupp
 
     consumer.close();
 
-    val browser = session.createBrowser(queue("BROWSER.TEST"))
+    val browser = session.createBrowser(queue("BROWSER.TEST.RB"))
     val enumeration = browser.getEnumeration
 
     // browse the second
@@ -140,7 +140,7 @@ class QueueTest extends OpenwireTestSupp
     browser.close()
 
     // Re-open the consumer.
-    consumer = session.createConsumer(queue("BROWSER.TEST"));
+    consumer = session.createConsumer(queue("BROWSER.TEST.RB"));
     // Receive the second.
     consumer.receive(200) should be(outbound(1))
     // Receive the third.
@@ -153,7 +153,7 @@ class QueueTest extends OpenwireTestSupp
 
     val session = default_connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
 
-    val producer = session.createProducer(queue("BROWSER.TEST"))
+    val producer = session.createProducer(queue("BROWSER.TEST.BR"))
 
     val outbound = List(session.createTextMessage("First Message"),
                         session.createTextMessage("Second Message"),
@@ -162,11 +162,11 @@ class QueueTest extends OpenwireTestSupp
     producer.send(outbound(0))
 
     // create browser first
-    val browser = session.createBrowser(queue("BROWSER.TEST"))
+    val browser = session.createBrowser(queue("BROWSER.TEST.BR"))
     val enumeration = browser.getEnumeration
 
     // create consumer
-    val consumer = session.createConsumer(queue("BROWSER.TEST"))
+    val consumer = session.createConsumer(queue("BROWSER.TEST.BR"))
 
     // browse the first message
     enumeration.hasMoreElements should be(true)
@@ -233,7 +233,7 @@ class QueueTest extends OpenwireTestSupp
   test("Browse Close") {
     connect()
     val session = default_connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
-    val destination = queue("BROWSER.TEST")
+    val destination = queue("BROWSER.TEST.BC")
 
     val outbound = List(session.createTextMessage("First Message"),
                         session.createTextMessage("Second Message"),