Add shovel config

propertyguru · Apr 11, 2019 · 4c5ffe5 · 4c5ffe5
1 parent e117efc
commit 4c5ffe5
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/rabbitmq/files/shovel.sh b/rabbitmq/files/shovel.sh
@@ -0,0 +1,4 @@
+#!/bin/bash
+## Create shovel users-forward-converter-delta
+
+rabbitmqctl -p users-api set_parameter shovel users-forward-converter-delta  '{"src-protocol": "amqp091", "src-uri": "amqp://usersapi@/users-api", "src-exchange": "users-api", "dest-protocol": "amqp091", "dest-uri": "amqp://data-bridge@/data-bridge", "dest-exchange": "forward-converter", "ack-mode": "on-confirm","src-delete-after": "never"}'
diff --git a/rabbitmq/shovel-config.sls b/rabbitmq/shovel-config.sls
@@ -0,0 +1,7 @@
+include:  
+  - rabbitmq
+
+create_dynamic_shovel:
+  cmd.script:
+    - source: salt://rmq/files/shovel.sh
+    - unless: rabbitmqctl eval 'rabbit_shovel_status:status().' | grep running