configure user demo

Author: skunkworker

.github/workflows/test.yaml

@@ -28,6 +28,7 @@ jobs:
         # Use the service name 'rabbitmq' as the host, not localhost
         RABBITMQ_URL: "amqp://demo:demo@rabbitmq:5672"
         RABBITMQ_HOST: rabbitmq
+        RABBITMQ_MANAGEMENT_URL: "http://demo:demo@rabbitmq:15672"
 
     services:
       rabbitmq:
@@ -83,6 +84,11 @@ jobs:
           echo "RabbitMQ failed to start"
           exit 1
 
+      - name: Configure RabbitMQ Management user "demo"
+        run: |
+         docker exec ${{ job.services.rabbitmq.id }} rabbitmqctl set_user_tags "demo" administrator
+         docker exec ${{ job.services.rabbitmq.id }} rabbitmqctl set_permissions -p / "demo" ".*" ".*" ".*"
+
       - name: Run Tests
         run : |
          git config --global --add safe.directory /__w/action_subscriber/action_subscriber

spec/integration/automatic_reconnect_spec.rb

@@ -12,10 +12,10 @@ def spoke
       default_routes_for GusSubscriber
     end
   end
-  let(:rabbitmq_host) {
-    ENV["RABBITMQ_HOST"] || "127.0.0.1"
+  let(:rabbitmq_management_url) {
+    ENV["RABBITMQ_MANAGEMENT_URL"] || "http://127.0.0.1:15672"
   }
-  let(:http_client) { RabbitMQ::HTTP::Client.new("http://#{rabbitmq_host}:15672") }
+  let(:http_client) { RabbitMQ::HTTP::Client.new(rabbitmq_management_url) }
   let(:subscriber) { GusSubscriber }
 
   it "reconnects when a connection drops" do

spec/integration/consumer_cancellation_spec.rb

@@ -14,10 +14,10 @@ def created
     end
   end
 
-  let(:rabbitmq_host) {
-    ENV["RABBITMQ_HOST"] || "127.0.0.1"
+  let(:rabbitmq_management_url) {
+    ENV["RABBITMQ_MANAGEMENT_URL"] || "http://127.0.0.1:15672"
   }
-  let(:http_client) { ::RabbitMQ::HTTP::Client.new("http://#{rabbitmq_host}:15672") }
+  let(:http_client) { RabbitMQ::HTTP::Client.new(rabbitmq_management_url) }
   let(:subscriber) { ::YoloSubscriber }
 
   it "resubscribes on cancellation" do