spec/lib/adapters/rabbitmq/connection_spec.rb in basquiat-1.2.0 vs spec/lib/adapters/rabbitmq/connection_spec.rb in basquiat-1.3.0.pre.1

@@ -2,44 +2,39 @@
 require 'basquiat/adapters/rabbitmq_adapter'
 
 describe Basquiat::Adapters::RabbitMq::Connection do
   subject(:connection) { Basquiat::Adapters::RabbitMq::Connection }
 
-  let(:servers) do
-    [{ host: ENV.fetch('BASQUIAT_RABBITMQ_1_PORT_5672_TCP_ADDR') { 'localhost' },
-       port: ENV.fetch('BASQUIAT_RABBITMQ_1_PORT_5672_TCP_PORT') { 5672 } }]
+  let(:hosts) do
+    [ENV.fetch('BASQUIAT_RABBITMQ_1_PORT_5672_TCP_ADDR') { 'localhost' }]
   end
 
-  before(:each) do
-    Basquiat.configure { |c| c.logger = Logger.new('log/basquiat.log') }
-  end
-
   it '#connected?' do
-    conn = connection.new(servers: servers)
+    conn = connection.new(hosts: hosts)
     expect(conn.connected?).to be_falsey
     conn.start
     expect(conn.connected?).to_not be_truthy
     conn.disconnect
   end
 
   context 'failover' do
     let(:failover) do
-      { default_timeout: 0.2, max_retries: 2, threaded: false }
+      { default_timeout: 0.2, max_retries: 2, connection_timeout: 0.3 }
     end
 
-    before(:each) { servers.unshift(host: 'localhost', port: 1234) }
+    before(:each) { hosts.unshift('172.168.0.124') }
 
     it 'tries a reconnection after a few seconds' do
-      conn = connection.new(servers:  [host: 'localhost', port: 1234],
+      conn = connection.new(hosts:    ['172.168.0.124'],
                             failover: { default_timeout: 0.2, max_retries: 1 })
       expect { conn.start }.to raise_error(Bunny::TCPConnectionFailed)
       conn.close
     end
 
     it 'uses another server after all retries on a single one' do
-      conn = connection.new(servers: servers, failover: failover)
+      conn = connection.new(hosts: hosts, failover: failover)
       expect { conn.start }.to_not raise_error
-      expect(conn.current_server_uri).to match "#{ENV.fetch('BASQUIAT_RABBITMQ_1_PORT_5672_TCP_PORT') { 5672 }}"
+      expect(conn.host).to match "#{ENV.fetch('BASQUIAT_RABBITMQ_1_PORT_5672_TCP_ADDR') { 'localhost' }}"
       conn.close
     end
   end
 end