diff options
| author | Alan Conway <aconway@apache.org> | 2011-11-04 20:27:13 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2011-11-04 20:27:13 +0000 |
| commit | 29e3b04915ef30f7e0f769cc1ee3994d99711fef (patch) | |
| tree | 02e49caec0e4e7699413d36eab177a3d5bbb732d /qpid/cpp/src/tests/qpid-cpp-benchmark | |
| parent | 561fe4dd6234c085dc55bbd430dcab7427d2db29 (diff) | |
| download | qpid-python-qpid-2920-active.tar.gz | |
QPID-2920: Batch acquire/dequeue messages in cluster.qpid-2920-active
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1197749 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/qpid-cpp-benchmark')
| -rwxr-xr-x | qpid/cpp/src/tests/qpid-cpp-benchmark | 3 |
1 files changed, 1 insertions, 2 deletions
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); |