           @_connectTimeout = setTimeout ()=>
             debug 1, ()-> return "Connection timeout triggered"
             @close()
-            cb?({code:'T',message:'Connection Timeout'})
+            cb?({code:'T', message:'Connection Timeout', host:@connectionOptions.host, port:@connectionOptions.port})
           , @connectionOptions.connectTimeout
 
         @connection.on 'error', (e, r)=>

    debug 1, ()=> return "Connected to #{@connectionOptions.host}:#{@connectionOptions.port}"

  _connected: ()->
    @_resetHeartbeatTimer()
    @_setupParser(@_reestablishChannels)
    clearTimeout(@_connectTimeout)

  _reestablishChannels: ()=>
    async.forEachSeries _.keys(@channels), (channel, done)=>


if process.env.AMQP_TEST?
  defaults.connection.reconnectDelayTime = 100
  defaults.connection.connectTimeout     = 100


class Connection extends EventEmitter
