From d41c4461932cd44629314fa11c8435764c31a6e3 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Tue, 26 May 2009 18:22:48 +0000 Subject: Persistent cluster test added which checks for recovery of queue and messages after all nodes in a cluster are killed. Test does not run if no store is loaded. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@778827 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/testlib.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'cpp/src/tests/testlib.py') diff --git a/cpp/src/tests/testlib.py b/cpp/src/tests/testlib.py index 64b6396d5b..89967c2d44 100644 --- a/cpp/src/tests/testlib.py +++ b/cpp/src/tests/testlib.py @@ -188,7 +188,7 @@ class TestBaseCluster(TestBase): args += " --load-module %s" % self._storeLib self._clusterDict[clusterName][nodeNumber] = self.startBroker(args, logFile) - def createCluster(self, clusterName, numberNodes): + def createCluster(self, clusterName, numberNodes = 0): """Create a cluster containing an initial number of nodes""" self._clusterDict[clusterName] = {} for n in range(0, numberNodes): @@ -215,7 +215,9 @@ class TestBaseCluster(TestBase): def getClusterTupleList(self, clusterName): """Get list of (pid, port) tuples of all nodes in named cluster""" - return self._clusterDict[clusterName].values() + if clusterName in self._clusterDict: + return self._clusterDict[clusterName].values() + return [] def getNumClusterBrokers(self, clusterName): """Get total number of brokers in named cluster""" -- cgit v1.2.1