summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java70
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java28
2 files changed, 34 insertions, 64 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
index cd5a48d0af..ac07372c68 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
@@ -45,7 +45,7 @@ public class PersistentStoreTest extends QpidTestCase
_con = getConnection();
_con.start();
_session = _con.createSession(true, Session.AUTO_ACKNOWLEDGE);
- _destination = _session.createQueue(this.getClass().getName());
+ _destination = _session.createQueue(getTestQueueName());
_consumer = _session.createConsumer(_destination);
_consumer.close();
@@ -70,16 +70,16 @@ public class PersistentStoreTest extends QpidTestCase
assertNull("No more messages should be received", _consumer.receive(100));
}
- /**
- * starts the server, sends 100 messages, restarts the server and gets 100 messages back
- * the test formerly referred to as BDB-Qpid-1
- * @throws Exception
- */
- public void testStartStop() throws Exception
- {
- restartBroker();
- checkMessages();
- }
+// /**
+// * starts the server, sends 100 messages, restarts the server and gets 100 messages back
+// * the test formerly referred to as BDB-Qpid-1
+// * @throws Exception
+// */
+// public void testStartStop() throws Exception
+// {
+// restartBroker(); -- Not Currently a gracefull restart so not BDB-Qpid-1
+// checkMessages();
+// }
/**
@@ -89,24 +89,23 @@ public class PersistentStoreTest extends QpidTestCase
*/
public void testForcibleStartStop() throws Exception
{
- nukeBroker();
- startBroker();
- checkMessages();
- }
-
- /**
- * starts the server, sends 100 committed messages, 5 uncommited ones,
- * restarts the server and gets 100 messages back
- * the test formerly referred to as BDB-Qpid-5
- * @throws Exception
- */
- public void testStartStopMidTransaction() throws Exception
- {
- sendMessage(_session, _destination, 5);
restartBroker();
checkMessages();
}
+// /**
+// * starts the server, sends 100 committed messages, 5 uncommited ones,
+// * restarts the server and gets 100 messages back
+// * the test formerly referred to as BDB-Qpid-5
+// * @throws Exception
+// */
+// public void testStartStopMidTransaction() throws Exception
+// {
+// sendMessage(_session, _destination, 5);
+// restartBroker(); -- Not Currently a gracefull restart so not BDB-Qpid-1
+// checkMessages();
+// }
+
/**
* starts the server, sends 100 committed messages, 5 uncommited ones,
* nukes and starts the server and gets 100 messages back
@@ -116,8 +115,7 @@ public class PersistentStoreTest extends QpidTestCase
public void testForcibleStartStopMidTransaction() throws Exception
{
sendMessage(_session, _destination, 5);
- nukeBroker();
- startBroker();
+ restartBroker();
checkMessages();
}
@@ -136,14 +134,14 @@ public class PersistentStoreTest extends QpidTestCase
checkMessages();
}
- /**
- * starts the server, sends 50 committed messages, copies $QPID_WORK to a new location,
- * sends 10 messages, stops the server, nukes the store, restores the copy, starts the server
- * checks that we get the first 50 back.
- */
- public void testHotBackup()
- {
-
- }
+// /**
+// * starts the server, sends 50 committed messages, copies $QPID_WORK to a new location,
+// * sends 10 messages, stops the server, nukes the store, restores the copy, starts the server
+// * checks that we get the first 50 back.
+// */
+// public void testHotBackup()
+// {
+// -- removing as this will leave 100msgs on a queue
+// }
}
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java
index b6ee6083b2..e7218d6975 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/test/utils/QpidTestCase.java
@@ -521,34 +521,6 @@ public class QpidTestCase extends TestCase
}
}
- public void nukeBroker() throws Exception
- {
- nukeBroker(0);
- }
-
- public void nukeBroker(int port) throws Exception
- {
- Process proc = _brokers.get(getPort(port));
- if (proc == null)
- {
- stopBroker(port);
- }
- else
- {
- String command = "pkill -KILL -f " + getBrokerCommand(getPort(port));
- try
- {
- Runtime.getRuntime().exec(command);
- }
- catch (Exception e)
- {
- // Can't do that, try the old fashioned way
- _logger.warn("Could not run " + command + ", killing with stopBroker()");
- stopBroker(port);
- }
- }
- }
-
/**
* Attempt to set the Java Broker to use the BDBMessageStore for persistence
* Falling back to the DerbyMessageStore if