blob: 6c901d94240615ddcf585ef7628489995b87dde9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
# -*- coding: utf-8 -*-
require "logger"
require "./connection"
module Aclog
module Collector
class Worker
def initialize
@logger = Logger.new(STDOUT)
@logger.level = Settings.env == "development" ? Logger::DEBUG : Logger::INFO
end
def start
EM.run do
connection = EM.connect(Settings.receiver_host, Settings.receiver_port, Aclog::Collector::Connection, @logger)
stop = proc do
@logger.info("Quitting collector...")
connection.quit
EM.stop
end
Signal.trap(:INT, &stop)
Signal.trap(:TERM, &stop)
end
end
end
end
end
|
