stackforge-attic
/
murano-tests
Code Issues Proposed changes

Merge "Add queues deletion in RabbitMQ script"

This commit is contained in:
Jenkins 2014-03-06 13:52:12 +00:00 committed by Gerrit Code Review
parent d34a8f4fbf 406c3b0336
commit 54b8a0b583
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
infra/RabbitMQ.py
View File

@ -25,13 +25,20 @@ password = args.password
vhost = args.vhostname
cl = Client(rabbitmq_url, rabbitmq_user, rabbitmq_password)
assert cl.is_alive()
for i in cl.get_all_vhosts():
if i['name'] == vhost:
cl.delete_vhost(i['name'])
for i in cl.get_users():
if i['name'] == user:
cl.delete_user(i['name'])
for queue in cl.get_queues():
if queue['vhost'] == vhost:
cl.purge_queue(vhost, queue['name'])
cl.delete_queue(vhost, queue['name'])
for vhost_ in cl.get_all_vhosts():
if vhost_['name'] == vhost:
cl.delete_vhost(vhost_['name'])
for user_ in cl.get_users():
if user_['name'] == user:
cl.delete_user(user_['name'])
cl.create_vhost(vhost)
cl.create_user(user, password, tags='administrator')
cl.set_vhost_permissions(vhost, user, '.*', '.*', '.*')
cl.set_vhost_permissions(vhost, user, '.*', '.*', '.*')