2417 - qr dedicated rabbitmq

contrib/datawave-quickstart/docker/pom.xml

@@ -17,6 +17,7 @@
         <dist.maven>apache-maven-3.8.8-bin.tar.gz</dist.maven>
         <dist.wildfly>wildfly-17.0.1.Final.tar.gz</dist.wildfly>
         <dist.zookeeper>apache-zookeeper-3.7.2-bin.tar.gz</dist.zookeeper>
+        <docker.image.prefix />
         <skipIngest>false</skipIngest>
         <url.accumulo>https://dlcdn.apache.org/accumulo/2.1.3/${dist.accumulo}</url.accumulo>
         <url.hadoop>https://dlcdn.apache.org/hadoop/common/hadoop-3.3.6/${dist.hadoop}</url.hadoop>

docker/bootstrap.sh

@@ -3,6 +3,7 @@ echo
 
 # Ensure that permissions are set correctly for the config files
 chmod -R 755 config pki rabbitmq-config
+chmod -R 755 config pki qr-rabbitmq-config
 
 DW_HOSTNAME=$(hostname)
 DW_HOSTNAME=${DW_HOSTNAME%%.*}

docker/config/application-querymessaging.yml

@@ -7,5 +7,7 @@ datawave:
       backend: ${messaging.backend}
       rabbitmq:
         maxMessageSizeBytes: ${messaging.maxMessageSizeBytes}
+      qr-rabbitmq:
+        maxMessageSizeBytes: ${messaging.maxMessageSizeBytes}
       kafka:
         partitions: 2

docker/config/application.yml

@@ -66,6 +66,12 @@ spring:
     publisher-confirm-type: simple
     publisher-confirms: true
     publisher-returns: true
+  qr-rabbitmq:
+    host: ${MESSAGING_SERVER_HOSTNAME:localhost}
+    port: 5673
+    publisher-confirm-type: simple
+    publisher-confirms: true
+    publisher-returns: true
   cloud:
     consul:
       enabled: false

docker/docker-compose.yml

@@ -80,6 +80,24 @@ services:
       consul:
         condition: service_started
 
+  qr-rabbitmq:
+    image: docker.io/rabbitmq:3.12.4
+    volumes:
+      - ${RABBITMQ_CONFIG_DIR:-./rabbitmq-config}:/etc/rabbitmq
+      - ./logs:/logs
+    environment:
+      - TCP_PORTS=25672, 15672, 5672
+      - RABBITMQ_ERLANG_COOKIE="mycookie"
+    ports:
+      - "5673:5672"
+      - "15673:15672"
+      - "25673:25672"
+    networks:
+      - demo
+    depends_on:
+      consul:
+        condition: service_started
+
   # When auto.create.topics.enable is true, this causes deleted topics to be recreated at random.  So, leave it disabled.
   kafka:
     profiles:

docker/rabbitmq-config/rabbitmq.conf

@@ -13,4 +13,4 @@ cluster_formation.consul.svc_ttl = 30
 cluster_formation.consul.deregister_after = 90
 cluster_partition_handling = autoheal
 # Enable the guest user
-loopback_users.guest = false
+loopback_users.guest = false