# File lib/amqp/client.rb, line 20 def initialize(opts = {}) @settings = opts extend AMQP.client @_channel_mutex = Mutex.new @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 # TCP connection "openness" @tcp_connection_established = false # AMQP connection "openness" @connected = false end