   createConnectTimer: ->
     @connectTimer = setTimeout(@connectTimeout, @config.options.connectTimeout)
 
+  createRequestTimer: ->
+    if @config.options.requestTimeout
+      @requestTimer = setTimeout(@requestTimeout, @config.options.requestTimeout)
+
   connectTimeout: =>
     message = "Failed to connect to #{@config.server}:#{@config.options.port} in #{@config.options.connectTimeout}ms"
 

      @debug.log(message)
      false
    else
      @messageIo.sendMessage(TYPE.ATTENTION)
      @transitionTo(@STATE.SENT_ATTENTION)
      true

  cleanupConnection: ->
    if !@closed
      @clearConnectTimer()
      @clearRequestTimer()
      @closeConnection()
      @emit('end')
      @closed = true
