diff options
| author | Alan Conway <aconway@apache.org> | 2012-09-17 15:52:07 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-09-17 15:52:07 +0000 |
| commit | 0d113ca0d9e08341a749b4cc5916c855b423941b (patch) | |
| tree | adcd8010b4df6100b2ed280baf0194da180eb69d /qpid/cpp/src/tests | |
| parent | 238cac00bfe6747d5ecf1e9bfa7049b90bdb2951 (diff) | |
| download | qpid-python-0d113ca0d9e08341a749b4cc5916c855b423941b.tar.gz | |
QPID-4290: HA auto-delete queues are not deleted (Author: Andy Goldstein)
ReplicatingSubscription was being counted as a consumer and preventing
auto-delete queues from being deleted.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1386672 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests')
| -rwxr-xr-x | qpid/cpp/src/tests/ha_tests.py | 30 |
1 files changed, 18 insertions, 12 deletions
diff --git a/qpid/cpp/src/tests/ha_tests.py b/qpid/cpp/src/tests/ha_tests.py index 92442b465a..e32077f219 100755 --- a/qpid/cpp/src/tests/ha_tests.py +++ b/qpid/cpp/src/tests/ha_tests.py @@ -677,20 +677,26 @@ class ReplicationTests(BrokerTest): def test_auto_delete_exclusive(self): """Verify that we ignore auto-delete, exclusive, non-auto-delete-timeout queues""" - cluster = HaCluster(self,2) - s = cluster[0].connect().session() - s.receiver("exad;{create:always,node:{x-declare:{exclusive:True,auto-delete:True}}}") - s.receiver("ex;{create:always,node:{x-declare:{exclusive:True}}}") - s.receiver("ad;{create:always,node:{x-declare:{auto-delete:True}}}") - s.receiver("time;{create:always,node:{x-declare:{exclusive:True,auto-delete:True,arguments:{'qpid.auto_delete_timeout':1}}}}") - s.receiver("q;{create:always}") + cluster = HaCluster(self, 2) + s0 = cluster[0].connect().session() + s0.receiver("exad;{create:always,node:{x-declare:{exclusive:True,auto-delete:True}}}") + s0.receiver("ex;{create:always,node:{x-declare:{exclusive:True}}}") + ad = s0.receiver("ad;{create:always,node:{x-declare:{auto-delete:True}}}") + s0.receiver("time;{create:always,node:{x-declare:{exclusive:True,auto-delete:True,arguments:{'qpid.auto_delete_timeout':1}}}}") + s0.receiver("q;{create:always}") - s = cluster[1].connect_admin().session() + s1 = cluster[1].connect_admin().session() cluster[1].wait_backup("q") - assert not valid_address(s, "exad") - assert valid_address(s, "ex") - assert valid_address(s, "ad") - assert valid_address(s, "time") + assert not valid_address(s1, "exad") + assert valid_address(s1, "ex") + assert valid_address(s1, "ad") + assert valid_address(s1, "time") + + # Verify that auto-delete queues are not kept alive by + # replicating subscriptions + ad.close() + s0.sync() + assert not valid_address(s0, "ad") def test_broker_info(self): """Check that broker information is correctly published via management""" |