diff options
| author | Alan Conway <aconway@apache.org> | 2013-06-17 14:19:10 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2013-06-17 14:19:10 +0000 |
| commit | 1d55ce68b88256a4de0329d3104436b0c581000c (patch) | |
| tree | e94c576b90ee33caddd96d6efccdbf2bab51080c /qpid/cpp/src/tests/qpid-cluster-benchmark | |
| parent | 0fb93ca81a3517d66339b3e890282ea4c82546a9 (diff) | |
| download | qpid-python-1d55ce68b88256a4de0329d3104436b0c581000c.tar.gz | |
QPID-4348: HA Use independent sequence numbers for identifying messages
Previously HA code used queue sequence numbers to identify messasges.
This assumes that message sequence is identical on primary and backup.
Implementing new features (for example transactions) requires that we tolerate
ordering differences between primary and backups.
This patch introduces a new, queue-scoped HA sequence number managed by the HA
plugin. The HA ID is set *before* the message is enqueued and assigned a queue
sequence number. This means it is possible to identify messages before they are
enqueued, e.g. messages in an open transaction.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1493771 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/qpid-cluster-benchmark')
| -rwxr-xr-x | qpid/cpp/src/tests/qpid-cluster-benchmark | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/tests/qpid-cluster-benchmark b/qpid/cpp/src/tests/qpid-cluster-benchmark index 3e6b805692..b72964c1a7 100755 --- a/qpid/cpp/src/tests/qpid-cluster-benchmark +++ b/qpid/cpp/src/tests/qpid-cluster-benchmark @@ -1,5 +1,5 @@ #!/bin/sh -# +echo# # Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE file # distributed with this work for additional information @@ -26,8 +26,8 @@ REPEAT="--repeat 10" QUEUES="-q 6" SENDERS="-s 3" RECEIVERS="-r 3" -BROKERS= # Local broker -CLIENT_HOSTS= # No ssh, all clients are local +BROKERS= # Local broker +CLIENT_HOSTS= # No ssh, all clients are local # Connection options TCP_NODELAY=false RECONNECT=true |