valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-07 17:09:03 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #6430 from saurabhsurana/rabbitmq-module-add-commands

Browse Source 
added list_queues commands
This commit is contained in:
Joseph Hall 2013-07-30 07:25:20 -07:00
commit 08c123fa98
1 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
salt/modules/rabbitmq.py
View File

@ -305,3 +305,30 @@ def force_reset(runas=None):
runas=runas)
return res
def list_queues(*kwargs):
'''
Returns queue details of the / virtual host
Example::
salt '*' rabbitmq.list_queues messages consumers
'''
res = __salt__['cmd.run'](
'rabbitmqctl list_queues {0}'.format(' '.join(list(kwargs))))
return res
def list_queues_vhost(vhost, *kwargs):
'''
Returns queue details of specified virtual host.
This command will consider first parameter as the vhost name and rest will be treated as queueinfoitem.
Also rabbitmqctl's -p parameter will be passed by salt, it should not be provided by salt command
For getting details on vhost '/', use list_queues instead).
Example::
salt '*' rabbitmq.list_queues messages consumers
'''
res = __salt__['cmd.run'](
'rabbitmqctl list_queues -p {0} {1}'.format(vhost, ' '.join(list(kwargs))))
return res