Python3 support; add node: param to native rabbitmq_ modules

Author: merifri

defaults/main.yml

@@ -78,6 +78,7 @@ rabbitmq_redhat_version: 3.8.11
 rabbitmq_extra_vhosts: []
 # - name: /
 #   state: present
+#   node: "rabbit"
 
 # Define admin user to create in order to login to WebUI
 rabbitmq_users:

tasks/rabbitmq_users.yml

@@ -10,6 +10,7 @@
     tags: "{{ item['tags']|default(omit) }}"
     permissions: "{{ item['permissions']|default(omit) }}"
     state: present
+    node: "{{ item['node'] | default('rabbit') }}"
   become: true
   loop: "{{ rabbitmq_users }}"
   loop_control:
@@ -30,6 +31,7 @@
     tags: "{{ item['tags']|default(omit) }}"
     permissions: "{{ item['permissions']|default(omit) }}"
     state: present
+    node: "{{ item['node'] | default('rabbit') }}"
   run_once: yes
   delegate_to: "{{ rabbitmq_master }}"
   become: true

tasks/rabbitmq_vhosts.yml

@@ -3,7 +3,7 @@
   rabbitmq_vhost:
     name: "{{ item['name'] }}"
     state: "{{ item['state'] }}"
-  become: true
+    node: "{{ item['node'] | default('rabbit') }}"
   with_items: "{{ rabbitmq_extra_vhosts }}"
   run_once: "{{ rabbitmq_enable_clustering is defined and rabbitmq_enable_clustering }}"
   register: rabbitmq_created_vhosts

templates/etc/rabbitmq/rabbitmq-env.conf.j2

@@ -1,6 +1,6 @@
 # {{ ansible_managed }}
 # Note that the variables do not have the RABBITMQ_ prefix.
 #
-{% for key, value in rabbitmq_env_config.items() %}
+{% for key,value in rabbitmq_env_config.items() %}
 {{ key }}={{ value }}
 {% endfor %}