summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2009-10-01 15:20:51 +0000
committerRobert Gemmell <robbie@apache.org>2009-10-01 15:20:51 +0000
commita27debd4d1711ecdb9980419325f0707bb13c3f7 (patch)
treec166d413f6410b2b89fe5b571b35736893d7e6a3
parenta2900c87bcedcc99044a76d932e3fe6d35e02fb1 (diff)
downloadqpid-python-a27debd4d1711ecdb9980419325f0707bb13c3f7.tar.gz
QPID-2125: Make FailoverBaseCase set the second brokers QPID_WORK as a subdirectory of the first instead of /tmp, allowing common cleanBroker() execution via QpidTestCase. Update QueueBrowserAutoAckTest to use the getTestQueueName() helper method instead of creating its own time-based queue names
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@820685 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java2
-rw-r--r--java/systests/src/main/java/org/apache/qpid/test/utils/FailoverBaseCase.java5
2 files changed, 2 insertions, 5 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java b/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
index 62b54d3086..2e625f95c0 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
@@ -61,7 +61,7 @@ public class QueueBrowserAutoAckTest extends FailoverBaseCase
setupSession();
- _queue = _clientSession.createQueue(getName()+System.currentTimeMillis());
+ _queue = _clientSession.createQueue(getTestQueueName());
_clientSession.createConsumer(_queue).close();
//Ensure there are no messages on the queue to start with.
diff --git a/java/systests/src/main/java/org/apache/qpid/test/utils/FailoverBaseCase.java b/java/systests/src/main/java/org/apache/qpid/test/utils/FailoverBaseCase.java
index 9a8fb8fde0..440bc31fe9 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/utils/FailoverBaseCase.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/utils/FailoverBaseCase.java
@@ -22,8 +22,6 @@ package org.apache.qpid.test.utils;
import javax.jms.Connection;
-import org.apache.qpid.util.FileUtils;
-
public class FailoverBaseCase extends QpidTestCase
{
@@ -54,7 +52,7 @@ public class FailoverBaseCase extends QpidTestCase
protected void setUp() throws java.lang.Exception
{
super.setUp();
- setSystemProperty("QPID_WORK", System.getProperty("java.io.tmpdir")+"/"+getFailingPort());
+ setSystemProperty("QPID_WORK", System.getProperty("QPID_WORK")+"/"+getFailingPort());
startBroker(failingPort);
}
@@ -78,7 +76,6 @@ public class FailoverBaseCase extends QpidTestCase
{
stopBroker(_broker.equals(VM)?FAILING_PORT:FAILING_PORT);
super.tearDown();
- FileUtils.deleteDirectory(System.getProperty("java.io.tmpdir")+"/"+getFailingPort());
}