lib/splash/transports/rabbitmq.rb in prometheus-splash-0.4.3 vs lib/splash/transports/rabbitmq.rb in prometheus-splash-0.4.4

- old
+ new

@@ -19,11 +19,11 @@ creds = "#{@config[:rabbitmq][:user]}:#{@config[:rabbitmq][:passwd]}@" @url << creds end @url << "#{host}:#{port}#{vhost}" begin - @connection = Bunny.new url: @url + @connection = Bunny.new @url @connection.start @channel = @connection.create_channel @queue = @channel.queue options[:queue] rescue Bunny::Exception return { :case => :service_dependence_missing, :more => "RabbitMQ Transport not available." } @@ -49,10 +49,10 @@ creds = "#{@config[:rabbitmq][:user]}:#{@config[:rabbitmq][:passwd]}@" @url << creds end @url << "#{host}:#{port}#{vhost}" begin - @connection = Bunny.new url: @url + @connection = Bunny.new @url @connection.start @channel = @connection.create_channel rescue Bunny::Exception return { :case => :service_dependence_missing, :more => "RabbitMQ Transport not available." } end