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 } end end end