module NFAgent
  class Server
    def initialize
      Log.info("Starting up")
      Submitter.start_resubmission_thread
      chunk_handler = ChunkHandler.new
      chunk_handler.periodically_check_expired

      EM.run {
        EM.start_server "0.0.0.0", 10000, Event, chunk_handler
      }

      #Tail.tail(Config.proxy_log) do |line|
      #  chunk_handler.submit(line)
      #end
    end
  end
end