diff options
| author | Alan Conway <aconway@apache.org> | 2012-09-14 18:48:09 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-09-14 18:48:09 +0000 |
| commit | 5c73472bc29bb0dfcfda168ad81e0bb5025a3077 (patch) | |
| tree | 3eb45e481a828824e6c8e6589ad79150b67ecdeb /qpid/cpp/src/tests/brokertest.py | |
| parent | cef26777e4d9ed0874e21344994abfaf8fef9a60 (diff) | |
| download | qpid-python-5c73472bc29bb0dfcfda168ad81e0bb5025a3077.tar.gz | |
QPID-4223: HA Completion isn't sent when queue that has acquired but unacknowledged messages is deleted
- Extended ha_test.py test_failover_send_receive to kill backup as well as primary
- QueueRegistry::destroy was not calling observer.
- Primary removes disconnected brokers backups and expectedBackups
- Primary calls checkReady in all cases where broker is removed from expectedBackups
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1384882 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/brokertest.py')
| -rw-r--r-- | qpid/cpp/src/tests/brokertest.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/cpp/src/tests/brokertest.py b/qpid/cpp/src/tests/brokertest.py index aea4460e5a..dd09e8aa27 100644 --- a/qpid/cpp/src/tests/brokertest.py +++ b/qpid/cpp/src/tests/brokertest.py @@ -565,7 +565,7 @@ class NumberedSender(Thread): def __init__(self, broker, max_depth=None, queue="test-queue", connection_options=Cluster.CONNECTION_OPTIONS, - failover_updates=True, url=None): + failover_updates=True, url=None, args=[]): """ max_depth: enable flow control, ensure sent - received <= max_depth. Requires self.notify_received(n) to be called each time messages are received. @@ -576,7 +576,7 @@ class NumberedSender(Thread): "--address", "%s;{create:always}"%queue, "--connection-options", "{%s}"%(connection_options), "--content-stdin" - ] + ] + args if failover_updates: cmd += ["--failover-updates"] self.sender = broker.test.popen( cmd, expect=EXPECT_RUNNING, stdin=PIPE) |