Enable RabbitMQ mirrored queues

images/rabbitmq-cluster/cluster-rabbit.sh

@@ -13,5 +13,12 @@ echo NODENAME=rabbit@${HOSTNAME}.${SERVICE_NAME}-headless.${POD_NAMESPACE}.svc.c
 echo cluster_formation.k8s.hostname_suffix=.${SERVICE_NAME}-headless.${POD_NAMESPACE}.svc.cluster.local >> /etc/rabbitmq/rabbitmq.conf
 echo cluster_formation.k8s.service_name=${SERVICE_NAME}-headless >> /etc/rabbitmq/rabbitmq.conf
 
+# Replace placeholders with ENV values and copy file to rabbitmq conf directory
+if [ -e /etc/rabbitmq/definitions.json ]; then
+  sed -i -e "s/REPLACE_USERNAME/${RABBITMQ_DEFAULT_USER}/g" \
+	 -e "s/REPLACE_PASSWORD/${RABBITMQ_DEFAULT_PASS}/g" \
+	 -e "s/REPLACE_QUEUE_PATTERN/${RABBITMQ_DEFAULT_HA_PATTERN}/g" /etc/rabbitmq/definitions.json
+fi
+
 # start the server
 docker-entrypoint.sh rabbitmq-server

images/rabbitmq/Dockerfile

@@ -3,9 +3,20 @@ FROM rabbitmq:3-management
 ARG LAGOON_VERSION
 ENV LAGOON_VERSION=$LAGOON_VERSION
 
-COPY rabbitmq_delayed_message_exchange-3.7.0.ez /plugins
+ENV RABBITMQ_DEFAULT_USER=guest \
+    RABBITMQ_DEFAULT_PASS="guest"\
+    RABBITMQ_DEFAULT_HA_PATTERN='^lagoon-'
 
+
+COPY rabbitmq_delayed_message_exchange-3.7.0.ez /plugins
 RUN rabbitmq-plugins enable --offline rabbitmq_delayed_message_exchange;
 
-ENV RABBITMQ_DEFAULT_USER=guest \
-    RABBITMQ_DEFAULT_PASS="guest"
+# Copy startup schema with vhost, users, permissions and policies
+COPY definitions.json /etc/rabbitmq/definitions.json
+RUN chgrp 0 /etc/rabbitmq/definitions.json; chmod g+rw /etc/rabbitmq/definitions.json
+
+# Copy a custom entrypoint
+ADD cluster-rabbit.sh /
+RUN chgrp 0 /cluster-rabbit.sh; chmod +x /cluster-rabbit.sh
+
+ENTRYPOINT /cluster-rabbit.sh

images/rabbitmq/cluster-rabbit.sh

@@ -0,0 +1,11 @@
+#!/bin/sh
+
+# Replace placeholders with ENV values and copy file to rabbitmq conf directory from ConfigMap
+if [ -e /etc/rabbitmq/definitions.json ]; then
+  sed -i -e "s/REPLACE_USERNAME/${RABBITMQ_DEFAULT_USER}/g" \
+	 -e "s/REPLACE_PASSWORD/${RABBITMQ_DEFAULT_PASS}/g" \
+	 -e "s/REPLACE_QUEUE_PATTERN/${RABBITMQ_DEFAULT_HA_PATTERN}/g" /etc/rabbitmq/definitions.json
+fi
+
+# start the server
+docker-entrypoint.sh rabbitmq-server

images/rabbitmq/definitions.json

@@ -0,0 +1,14 @@
+{
+  "vhosts":[
+        {"name": "/"}
+  ],
+  "users": [
+        { "name": "REPLACE_USERNAME", "password": "REPLACE_PASSWORD", "tags": "administrator" }
+  ],
+  "permissions":[
+        { "user": "REPLACE_USERNAME", "vhost": "/", "configure": ".*", "write": ".*", "read": ".*" }
+  ],
+  "policies":[
+        {"vhost":"/","name":"lagoon-ha","pattern":"REPLACE_QUEUE_PATTERN", "definition":{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic","ha-sync-batch-size":5}}
+  ]
+}

services/broker/.lagoon.app.yml

@@ -120,6 +120,8 @@ objects:
                   key: RABBITMQ_PASSWORD
             - name: RABBITMQ_USE_LONGNAME
               value: "true"
+            - name: RABBITMQ_DEFAULT_HA_PATTERN
+              value: "^lagoon-"
             - name: POD_NAMESPACE
               valueFrom:
                 fieldRef: