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