 
 if process.env.AMQP_TEST?
   defaults.connection.reconnectDelayTime = 100
-  defaults.connection.connectTimeout     = 200
+  defaults.connection.connectTimeout     = 100
 
 
 class Connection extends EventEmitter

          @_connectTimeout = setTimeout ()=>
            debug 1, ()-> return "Connection timeout triggered"
            @close()
            cb?({code:'T',message:'Connection Timeout'})
          , @connectionOptions.connectTimeout

        @connection.on 'error', (e, r)=>

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

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

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