# File lib/amqp/client.rb, line 37 def connection_completed if @settings[:ssl].is_a? Hash start_tls @settings[:ssl] elsif @settings[:ssl] start_tls end log 'connected' # @on_disconnect = proc { raise Error, 'Disconnected from server' } unless @closing @reconnecting = false end @tcp_connection_established = true @buf = Buffer.new send_data HEADER send_data [1, 1, VERSION_MAJOR, VERSION_MINOR].pack('C4') if heartbeat = @settings[:heartbeat] init_heartbeat if (@settings[:heartbeat] = heartbeat.to_i) > 0 end end