diff options
| author | Alan Conway <aconway@apache.org> | 2011-10-12 15:54:07 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2011-10-12 15:54:07 +0000 |
| commit | f24028543c611c3c3710cc80871e6dadef41f67f (patch) | |
| tree | a7b11187d3f515667b7d7b8778b599986e6eef89 /qpid/cpp/src/tests/cluster_tests.py | |
| parent | f5c16134d2851d4e2966bec71d936e36e0297094 (diff) | |
| download | qpid-python-f24028543c611c3c3710cc80871e6dadef41f67f.tar.gz | |
QPID-3544: ACL denials while replicating exclusive queues to a newly joined node.
Disabled ACL during cluster update process.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1182451 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/cluster_tests.py')
| -rwxr-xr-x | qpid/cpp/src/tests/cluster_tests.py | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/qpid/cpp/src/tests/cluster_tests.py b/qpid/cpp/src/tests/cluster_tests.py index 610f6f9a04..0e80e06d34 100755 --- a/qpid/cpp/src/tests/cluster_tests.py +++ b/qpid/cpp/src/tests/cluster_tests.py @@ -115,19 +115,22 @@ class ShortTests(BrokerTest): acl=os.path.join(os.getcwd(), "policy.acl") aclf=file(acl,"w") aclf.write(""" -acl deny zag@QPID create queue -acl allow all all +acl allow zig@QPID all all +acl deny all all """) aclf.close() - cluster = self.cluster(2, args=["--auth", "yes", + cluster = self.cluster(1, args=["--auth", "yes", "--sasl-config", sasl_config, "--load-module", os.getenv("ACL_LIB"), "--acl-file", acl]) # Valid user/password, ensure queue is created. c = cluster[0].connect(username="zig", password="zig") - c.session().sender("ziggy;{create:always}") + c.session().sender("ziggy;{create:always,node:{x-declare:{exclusive:true}}}") c.close() + cluster.start() # Start second node. + + # Check queue is created on second node. c = cluster[1].connect(username="zig", password="zig") c.session().receiver("ziggy;{assert:always}") c.close() @@ -156,7 +159,7 @@ acl allow all all self.fail("Expected exception") except messaging.exceptions.UnauthorizedAccess: pass # make sure the queue was not created at the other node. - c = cluster[0].connect(username="zag", password="zag") + c = cluster[1].connect(username="zig", password="zig") try: s = c.session() s.sender("zaggy;{assert:always}") |