feat(queues): create/delete queues using cli

pillar.example

@@ -45,15 +45,16 @@ rabbitmq:
 
   queue:
     my-new-queue:
-      - user: saltstack
-      - passwd: 'password'
-      - durable: true
-      - auto_delete: false
-      - vhost: test_vhost
-      - arguments:
-          - 'x-message-ttl': 8640000
-          - 'x-expires': 8640000
-          - 'x-dead-letter-exchange': 'my-new-exchange'
+      ## note : dict format
+      user: saltstack
+      passwd: 'password'
+      durable: true
+      auto_delete: false
+      vhost: test_vhost
+      arguments:
+        - 'x-message-ttl': 8640000
+        - 'x-expires': 8640000
+        - 'x-dead-letter-exchange': 'my-new-exchange'
 
   exchange:
     my-new-exchange:

rabbitmq/config/clean.sls

@@ -12,6 +12,7 @@ include:
   - .policy.clean
   - .plugin.clean
   - .upstream.clean
+  - .queue.clean
   - .vhost.clean
   - .user.clean
   - .file.clean

rabbitmq/config/init.sls

@@ -5,6 +5,7 @@ include:
   - .file
   - .user
   - .vhost
+  - .queue
   - .policy
   - .plugin
   - .upstream

rabbitmq/config/queue/clean.sls

@@ -0,0 +1,19 @@
+# -*- coding: utf-8 -*-
+# vim: ft=sls
+
+{%- set tplroot = tpldir.split('/')[0] %}
+{%- from tplroot ~ "/map.jinja" import mapdata as rabbitmq with context %}
+{%- set sls_service_running = tplroot ~ '.service.running' %}
+
+include:
+  - {{ sls_service_running }}
+
+    {% for name, q in salt["pillar.get"]("rabbitmq:queue", {}).items() %}
+
+rabbitmq-config-queue-absent-{{ name }}:
+  cmd.run:
+    - name: /usr/local/sbin/rabbitmqadmin delete queue --vhost={{ q.vhost }} --username={{ q.user }} --password={{ q.passwd }} name={{ name }}
+    - require:
+      - service: {{ rabbitmq.service.name }}
+
+    {% endfor %}

rabbitmq/config/queue/init.sls

@@ -0,0 +1,5 @@
+# -*- coding: utf-8 -*-
+# vim: ft=sls
+
+include:
+  - .install

rabbitmq/config/queue/install.sls

@@ -0,0 +1,21 @@
+# -*- coding: utf-8 -*-
+# vim: ft=sls
+
+{%- set tplroot = tpldir.split('/')[0] %}
+{%- from tplroot ~ "/map.jinja" import mapdata as rabbitmq with context %}
+{%- set sls_service_running = tplroot ~ '.service.running' %}
+
+include:
+  - {{ sls_service_running }}
+
+    {% for name, q in salt["pillar.get"]("rabbitmq:queue", {}).items() %}
+
+rabbitmq-config-queue-present-{{ name }}:
+  cmd.run:
+    - name: /usr/local/sbin/rabbitmqadmin declare queue --vhost={{ q.vhost }} --username={{ q.user }} --password={{ q.passwd }} name={{ name }} durable={{ q.durable|to_bool|lower }} auto_delete={{ q.auto_delete|to_bool|lower }}
+
+    ### note: arguments='{# q.arguments|json #}' causes "mapping values are not allowed in this context"
+    - require:
+      - service: {{ rabbitmq.service.name }}
+
+    {% endfor %}