blob: a969835dad340d6d812792b46092e92206a36e10 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
#!/usr/bin/env ruby
require "bundler/setup"
$LOAD_PATH << File.expand_path("../lib", File.dirname(__FILE__))
require "killjoy"
log_file = ENV.fetch("LOG_FILE", "spec/fixtures/nginx.log")
parser = Killjoy::LogParser.new
#message_bus = Killjoy::MessageBus.new
message_bus = Killjoy::Kafka::MessageBus.new
Killjoy::Publisher.using(message_bus) do |publisher|
log_file = File.join(Dir.pwd, log_file)
lines = File.readlines(log_file)
loop do
lines.each do |line|
publisher.publish(parser.parse(line))
end
end
end
|
