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

exec input

Browse source
This commit is contained in:
Nick Ethier 2011-08-04 12:46:41 -06:00
parent a9f1790e7f
commit 4de29e2b32
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
lib/logstash/inputs/exec.rb
View file

@ -21,14 +21,14 @@ class LogStash::Inputs::Exec < LogStash::Inputs::Base
public
def register
#require "eventmffachine"
@logger.info(["Registering Exec Input", {:type => @type, :exec => @exec, :period => @period}])
end # def register
public
def run(queue)
while(1)
out = IO.popen(@exec)
e = to_event(out.readlines, @exec)
e = to_event(out.read, @exec)
queue << e
sleep @period
end