Enable RabbitMQ mirrored queues

images/rabbitmq-cluster/Dockerfile

@@ -9,6 +9,3 @@ ADD rabbitmq.conf /etc/rabbitmq/rabbitmq.conf
 RUN chgrp 0 /etc/rabbitmq/rabbitmq.conf; chmod g+rw /etc/rabbitmq/rabbitmq.conf
 
 ENV RABBITMQ_ERLANG_COOKIE=5188fd99edf19acfefcbb29a16f3d373aa01f66bfe89929852dfad2674d36af2
-
-# this is only used in the cluster version
-ADD cluster-rabbit.sh /

images/rabbitmq/Dockerfile

@@ -1,11 +1,25 @@
+FROM ${IMAGE_REPO:-lagoon}/commons as commons
 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='^$'\
+    RABBITMQ_DEFAULT_VHOST='/'
+
+COPY --from=commons /bin/ep /bin/fix-permissions /bin/
 
+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 fix-permissions /etc/rabbitmq/definitions.json
+
+# Copy a custom entrypoint
+COPY cluster-rabbit.sh /
+RUN chgrp 0 /cluster-rabbit.sh; chmod +x /cluster-rabbit.sh
+
+ENTRYPOINT /cluster-rabbit.sh

images/rabbitmq-cluster/cluster-rabbit.sh → images/rabbitmq/cluster-rabbit.sh

@@ -1,6 +1,11 @@
 #!/bin/sh
 
 
+# Replace ENV values in definitions.json
+if [ -e /etc/rabbitmq/definitions.json ]; then
+	/bin/ep /etc/rabbitmq/definitions.json
+fi
+
 # Check if the container runs in Kubernetes/OpenShift
 if [ -z "$POD_NAMESPACE" ]; then
   # Single container runs in docker
@@ -13,5 +18,6 @@ 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
 
+
 # start the server
 docker-entrypoint.sh rabbitmq-server

images/rabbitmq/definitions.json

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

services/broker/Dockerfile

@@ -1,2 +1,3 @@
 ARG IMAGE_REPO
 FROM ${IMAGE_REPO:-lagoon}/rabbitmq-cluster
+ENV RABBITMQ_DEFAULT_HA_PATTERN='^lagoon-'