From d490fba74749bcde972e5a0d95f84b165f8ea05e Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 11 Dec 2009 20:55:45 +0000 Subject: QPID-2266: error sending update: Enqueue capacity threshold exceeded Fix for the problem with a test to verify that messages going to the store have the same headers and content-size for an updatee or a broker that receives the publish directly. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@889813 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/brokertest.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'python') diff --git a/python/qpid/brokertest.py b/python/qpid/brokertest.py index 9fa79a220b..83d6c44d84 100644 --- a/python/qpid/brokertest.py +++ b/python/qpid/brokertest.py @@ -259,15 +259,15 @@ class Cluster: self.args += [ "--load-module", BrokerTest.cluster_lib ] self.start_n(count, expect=expect, wait=wait) - def start(self, name=None, expect=EXPECT_RUNNING, wait=True): + def start(self, name=None, expect=EXPECT_RUNNING, wait=True, args=[]): """Add a broker to the cluster. Returns the index of the new broker.""" if not name: name="%s-%d" % (self.name, len(self._brokers)) log.debug("Cluster %s starting member %s" % (self.name, name)) - self._brokers.append(self.test.broker(self.args, name, expect, wait)) + self._brokers.append(self.test.broker(self.args+args, name, expect, wait)) return self._brokers[-1] - def start_n(self, count, expect=EXPECT_RUNNING, wait=True): - for i in range(count): self.start(expect=expect, wait=wait) + def start_n(self, count, expect=EXPECT_RUNNING, wait=True, args=[]): + for i in range(count): self.start(expect=expect, wait=wait, args=args) # Behave like a list of brokers. def __len__(self): return len(self._brokers) @@ -289,6 +289,7 @@ class BrokerTest(TestCase): receiver_exec = os.getenv("RECEIVER_EXEC") sender_exec = os.getenv("SENDER_EXEC") store_lib = os.getenv("STORE_LIB") + test_store_lib = os.getenv("TEST_STORE_LIB") rootdir = os.getcwd() def configure(self, config): self.config=config -- cgit v1.2.1