           bot.Room(roomId).join (err, callback) ->
             bot.Room(roomId).listen()
 
-    bot.on "reconnect", (roomId) =>
+    bot.on "reconnect", (roomId) ->
       bot.Room(roomId).join (err, callback) ->
         bot.Room(roomId).listen()
 


  Room: (id) ->
    self = @

    show: (callback) ->
      self.post "/room/#{id}", "", callback

                  data = JSON.parse part
                  self.emit data.type, data.id, data.created_at, data.room_id, data.user_id, data.body
                catch err
                  logger.error "Campfire error: #{err}"

        response.on "end", ->
          logger.error "Streaming connection closed for room #{id}. :("
          setTimeout (->
            self.emit "reconnect", id
          ), 5000

        response.on "error", (err) ->
          logger.error "Campfire response error: #{err}"

      request.on "error", (err) ->
        logger.error "Campfire request error: #{err}"

      request.end()

