more

Author: skunkworker

spec/integration/automatic_reconnect_spec.rb

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

spec/integration/consumer_cancellation_spec.rb

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

spec/spec_helper.rb

@@ -24,7 +24,8 @@
 $TESTING = true
 ::ActionSubscriber::Logging.initialize_logger(nil)
 ::ActionSubscriber.setup_default_threadpool!
-# setup active publisher
+
+# load from action_subscriber.yml for both ActivePublisher and ActionSubscriber
 ::ActivePublisher::Configuration.configure_from_yaml_and_cli
 ::ActionSubscriber::Configuration.configure_from_yaml_and_cli