# File lib/amqp/client.rb, line 61 def initialize opts = {} @settings = opts extend AMQP.client @on_disconnect ||= proc{ raise Error, "Could not connect to server #{opts[:host]}:#{opts[:port]}" } timeout @settings[:timeout] if @settings[:timeout] errback{ @on_disconnect.call } unless @reconnecting @connected = false end