lib/nfagent/server.rb in nfagent-0.9.50 vs lib/nfagent/server.rb in nfagent-1.0.0

- old
+ new

@@ -1,18 +1,19 @@ module NFAgent class Server def run - Log.info("Starting up") + Log.info("Starting up: Listening on port #{Config.agent_port}") + Log.info("Data will be submitted to #{Config.service_host}:#{Config.service_port}") NFAgent::Plugin.load_plugins Log.info("Parsing #{Config.parse}") Log.info("Mode set to #{Config.mode}") chunk_handler = ChunkHandler.new poller = Poller.new EM.run { - EM.start_server "0.0.0.0", 10000, Event, chunk_handler, poller + EM.start_server "0.0.0.0", Config.agent_port, Event, chunk_handler, poller EM::PeriodicTimer.new(5) do chunk_handler.check_full_or_expired end EM::PeriodicTimer.new(120) do poller.send_heartbeat