github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #1023 from jordansissel/LOGSTASH-1860

Browse source 
Fixes LOGSTASH-1860
This commit is contained in:
Jordan Sissel 2014-02-04 15:11:25 -08:00
commit f9448d631e
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
lib/logstash/outputs/pipe.rb
View file

@ -36,7 +36,6 @@ class LogStash::Outputs::Pipe < LogStash::Outputs::Base
return unless output?(event)
command = event.sprintf(@command)
pipe = get_pipe(command)
if @message_format
output = event.sprintf(@message_format) + "\n"
@ -45,10 +44,12 @@ class LogStash::Outputs::Pipe < LogStash::Outputs::Base
end
begin
pipe = get_pipe(command)
pipe.puts(output)
rescue IOError, Errno::EPIPE => e
@logger.error("Error writing to pipe, closing pipe.", :command => command, :pipe => pipe)
drop_pipe(command)
retry
end
close_stale_pipes
@ -111,7 +112,7 @@ class PipeWrapper
@active = false
end
def method_missing?(m, *args)
def method_missing(m, *args)
if @pipe.respond_to? m
@pipe.send(m, *args)
else