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