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

@@ -190,11 +190,11 @@
     end
 
     def flush_buffer(tw)
       if lb = tw.line_buffer
         lb.chomp!
-        @parser.call(lb) { |time, record|
+        @parser.parse(lb) { |time, record|
           if time && record
             tag = if @tag_prefix || @tag_suffix
                     @tag_prefix + tw.tag + @tag_suffix
                   else
                     @tag
@@ -231,11 +231,11 @@
     end
 
     def convert_line_to_event(line, es)
       begin
         line.chomp!  # remove \n
-        @parser.call(line) { |time, record|
+        @parser.parse(line) { |time, record|
           if time && record
             es.add(time, record)
           else
             log.warn "pattern not match: #{line.inspect}"
           end
@@ -274,10 +274,10 @@
         }
       else
         lb ||= ''
         lines.each do |line|
           lb << line
-          @parser.call(lb) { |time, record|
+          @parser.parse(lb) { |time, record|
             if time && record
               convert_line_to_event(lb, es)
               lb = ''
             end
           }