lib/fluent/plugin/in_syslog.rb in fluentd-0.12.0.pre.3 vs lib/fluent/plugin/in_syslog.rb in fluentd-0.12.0

- old
+ new

@@ -131,11 +131,11 @@ return end pri = m[1].to_i text = m[2] - @parser.call(text) { |time, record| + @parser.parse(text) { |time, record| unless time && record log.warn "pattern not match: #{text.inspect}" return end @@ -146,10 +146,10 @@ log.error data.dump, :error => e.to_s log.error_backtrace end def receive_data(data, addr) - @parser.call(data) { |time, record| + @parser.parse(data) { |time, record| unless time && record log.warn "invalid syslog message", :data => data return end