Skip to content

Commit a2ad0ea

Browse files
committed
Make the plugins support Filebeat's pipelining
This PR fix a issue when using pipelining with filebeat. Fixes #89
1 parent d3637c4 commit a2ad0ea

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

lib/lumberjack/beats/server.rb

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -381,7 +381,8 @@ def compressed_payload(&block)
381381
transition(:header, 2)
382382

383383
# Parse the uncompressed payload.
384-
feed(original, &block)
384+
parser = self.class.new
385+
parser.feed(original, &block)
385386
end
386387
end # class Parser
387388

0 commit comments

Comments
 (0)