From 29e3b04915ef30f7e0f769cc1ee3994d99711fef Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 4 Nov 2011 20:27:13 +0000 Subject: QPID-2920: Batch acquire/dequeue messages in cluster. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1197749 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/qpid-cpp-benchmark | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'qpid/cpp/src/tests/qpid-cpp-benchmark') diff --git a/qpid/cpp/src/tests/qpid-cpp-benchmark b/qpid/cpp/src/tests/qpid-cpp-benchmark index 26283adb6c..9a0ee6b384 100755 --- a/qpid/cpp/src/tests/qpid-cpp-benchmark +++ b/qpid/cpp/src/tests/qpid-cpp-benchmark @@ -184,8 +184,7 @@ def recreate_queues(queues, brokers): # FIXME aconway 2011-05-04: new cluster async wiring, wait for changes to propagate for b in brokers: while queue_exists(q,b): time.sleep(0.1); - for q in queues: - s.sender("%s;{create:always}"%q) + s.sender("%s;{create:always}"%q) # FIXME aconway 2011-05-04: new cluster async wiring, wait for changes to propagate for b in brokers: while not queue_exists(q,b): time.sleep(0.1); -- cgit v1.2.1