svn commit: r960548 - /qpid/trunk/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java

[ritchiem]

Author: ritchiem
Date: Mon Jul  5 11:15:59 2010
New Revision: 960548

URL: http://svn.apache.org/viewvc?rev=960548&view=rev
Log:
QPID-2681 : Updated test to start broker before running test

Modified:
    
qpid/trunk/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java

Modified: 
qpid/trunk/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java
URL: 
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java?rev=960548&r1=960547&r2=960548&view=diff
==============================================================================
--- 
qpid/trunk/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java
 (original)
+++ 
qpid/trunk/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java
 Mon Jul  5 11:15:59 2010
@@ -113,7 +113,7 @@ public class GlobalQueuesTest extends Te
         setConfig("messageCount", String.valueOf(MAX_QUEUE_MESSAGE_COUNT - 1), 
false);
 
         //Start the broker
-        super.setUp();
+        startBroker();
 
         topicConsumer(Session.AUTO_ACKNOWLEDGE, false);
     }
@@ -134,7 +134,7 @@ public class GlobalQueuesTest extends Te
         setConfig("depth", String.valueOf(MESSAGE_SIZE * 9), false);
 
         //Start the broker
-        super.setUp();
+        startBroker();
 
         setMessageSize(MESSAGE_SIZE);
 
@@ -157,7 +157,7 @@ public class GlobalQueuesTest extends Te
         setConfig("messageAge", String.valueOf(DISCONNECTION_WAIT / 2), false);
 
         //Start the broker
-        super.setUp();
+        startBroker();
 
         topicConsumer(Session.AUTO_ACKNOWLEDGE, false);
     }
@@ -179,7 +179,7 @@ public class GlobalQueuesTest extends Te
         setConfig("messageCount", String.valueOf(MAX_QUEUE_MESSAGE_COUNT - 1), 
true);
 
         //Start the broker
-        super.setUp();
+        startBroker();
 
         topicConsumer(Session.AUTO_ACKNOWLEDGE, true);
     }
@@ -202,7 +202,7 @@ public class GlobalQueuesTest extends Te
         setConfig("depth", String.valueOf(MESSAGE_SIZE * 9), true);
 
         //Start the broker
-        super.setUp();
+        startBroker();
 
         setMessageSize(MESSAGE_SIZE);
 
@@ -227,7 +227,7 @@ public class GlobalQueuesTest extends Te
         setConfig("messageAge", String.valueOf(DISCONNECTION_WAIT / 5), true);
 
         //Start the broker
-        super.setUp();
+        startBroker();
 
         topicConsumer(Session.AUTO_ACKNOWLEDGE, true);
     }



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org