Native YAML - messaging (#3599)

lib/ansible/modules/extras/messaging/rabbitmq_binding.py

@@ -94,10 +94,18 @@ options:
 
 EXAMPLES = '''
 # Bind myQueue to directExchange with routing key info
-- rabbitmq_binding: name=directExchange destination=myQueue type=queue routing_key=info
+- rabbitmq_binding:
+    name: directExchange
+    destination: myQueue
+    type: queue
+    routing_key: info
 
 # Bind directExchange to topicExchange with routing key *.info
-- rabbitmq_binding: name=topicExchange destination=topicExchange type=exchange routing_key="*.info"
+- rabbitmq_binding:
+    name: topicExchange
+    destination: topicExchange
+    type: exchange
+    routing_key: *.info
 '''
 
 import requests

lib/ansible/modules/extras/messaging/rabbitmq_exchange.py

@@ -80,10 +80,14 @@ options:
 
 EXAMPLES = '''
 # Create direct exchange
-- rabbitmq_exchange: name=directExchange
+- rabbitmq_exchange:
+    name: directExchange
 
 # Create topic exchange on vhost
-- rabbitmq_exchange: name=topicExchange type=topic vhost=myVhost
+- rabbitmq_exchange:
+    name: topicExchange
+    type: topic
+    vhost: myVhost
 '''
 
 import requests

lib/ansible/modules/extras/messaging/rabbitmq_parameter.py

@@ -63,10 +63,11 @@ options:
 
 EXAMPLES = """
 # Set the federation parameter 'local_username' to a value of 'guest' (in quotes)
-- rabbitmq_parameter: component=federation
+- rabbitmq_parameter:
-                      name=local-username
+    component: federation
-                      value='"guest"'
+    name: local-username
-                      state=present
+    value: '"guest"'
+    state: present
 """
 
 class RabbitMqParameter(object):

lib/ansible/modules/extras/messaging/rabbitmq_plugin.py

@@ -56,7 +56,9 @@ options:
 
 EXAMPLES = '''
 # Enables the rabbitmq_management plugin
-- rabbitmq_plugin: names=rabbitmq_management state=enabled
+- rabbitmq_plugin:
+    names: rabbitmq_management
+    state: enabled
 '''
 
 import os

lib/ansible/modules/extras/messaging/rabbitmq_policy.py

@@ -74,13 +74,19 @@ options:
 
 EXAMPLES = '''
 - name: ensure the default vhost contains the HA policy via a dict
-  rabbitmq_policy: name=HA pattern='.*'
+  rabbitmq_policy:
+    name: HA
+    pattern: .*
   args:
     tags:
-      "ha-mode": all
+      ha-mode: all
 
 - name: ensure the default vhost contains the HA policy
-  rabbitmq_policy: name=HA pattern='.*' tags="ha-mode=all"
+  rabbitmq_policy:
+    name: HA
+    pattern: .*
+    tags:
+      - ha-mode: all
 '''
 class RabbitMqPolicy(object):
     def __init__(self, module, name):

lib/ansible/modules/extras/messaging/rabbitmq_queue.py

@@ -94,10 +94,15 @@ options:
 
 EXAMPLES = '''
 # Create a queue
-- rabbitmq_queue: name=myQueue
+- rabbitmq_queue:
+    name: myQueue
 
 # Create a queue on remote host
-- rabbitmq_queue: name=myRemoteQueue login_user=user login_password=secret login_host=remote.example.org
+- rabbitmq_queue:
+    name: myRemoteQueue
+    login_user: user
+    login_password: secret
+    login_host: remote.example.org
 '''
 
 import requests

lib/ansible/modules/extras/messaging/rabbitmq_user.py

@@ -107,20 +107,26 @@ options:
 EXAMPLES = '''
 # Add user to server and assign full access control on / vhost.
 # The user might have permission rules for other vhost but you don't care.
-- rabbitmq_user: user=joe
+- rabbitmq_user:
-                 password=changeme
+    user: joe
-                 vhost=/
+    password: changeme
-                 configure_priv=.*
+    vhost: /
-                 read_priv=.*
+    configure_priv: .*
-                 write_priv=.*
+    read_priv: .*
-                 state=present
+    write_priv: .*
+    state: present
 
 # Add user to server and assign full access control on / vhost.
 # The user doesn't have permission rules for other vhosts
-- rabbitmq_user: user=joe
+- rabbitmq_user:
-                 password=changeme
+    user: joe
-                 permissions=[{vhost='/', configure_priv='.*', read_priv='.*', write_priv='.*'}]
+    password: changeme
-                 state=present
+    permissions:
+      - vhost: /
+        configure_priv: .*
+        read_priv: .*
+        write_priv: .*
+    state: present
 '''
 
 class RabbitMqUser(object):

lib/ansible/modules/extras/messaging/rabbitmq_vhost.py

@@ -55,7 +55,9 @@ options:
 
 EXAMPLES = '''
 # Ensure that the vhost /test exists.
-- rabbitmq_vhost: name=/test state=present
+- rabbitmq_vhost:
+    name: /test
+    state: present
 '''
 
 class RabbitMqVhost(object):