summaryrefslogtreecommitdiff
path: root/qpid/java/broker-plugins
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2010-07-05 11:15:59 +0000
committerMartin Ritchie <ritchiem@apache.org>2010-07-05 11:15:59 +0000
commitfe0a8104595f24fc392254b1d0f9962a22d31e87 (patch)
treeda418fbc028edaa54d0553846e6137c28eac3d46 /qpid/java/broker-plugins
parent4630d06917e42b3dfca3d24e5895f53732f8c173 (diff)
downloadqpid-python-fe0a8104595f24fc392254b1d0f9962a22d31e87.tar.gz
QPID-2681 : Updated test to start broker before running test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@960548 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins')
-rw-r--r--qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java b/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java
index ca89df391d..ea8b5b7a65 100644
--- a/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java
+++ b/qpid/java/broker-plugins/experimental/slowconsumerdetection/src/test/java/org/apache/qpid/systest/GlobalQueuesTest.java
@@ -113,7 +113,7 @@ public class GlobalQueuesTest extends TestingBaseCase
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 TestingBaseCase
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 TestingBaseCase
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 TestingBaseCase
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 TestingBaseCase
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 TestingBaseCase
setConfig("messageAge", String.valueOf(DISCONNECTION_WAIT / 5), true);
//Start the broker
- super.setUp();
+ startBroker();
topicConsumer(Session.AUTO_ACKNOWLEDGE, true);
}