mirror of
https://github.com/elastic/logstash.git
synced 2025-04-23 22:27:21 -04:00
debug cleanup
This commit is contained in:
parent
270c7e4a1d
commit
b07c174856
2 changed files with 2 additions and 2 deletions
|
@ -110,6 +110,7 @@ class LogStash::Agent
|
|||
end
|
||||
end # filters.each
|
||||
|
||||
@logger.debug(["Event finished filtering", event])
|
||||
output_queue.push(event) unless event.cancelled?
|
||||
end # event pop
|
||||
end # Thread.new
|
||||
|
|
|
@ -41,7 +41,6 @@ class LogStash::File::Manager
|
|||
JThread.currentThread().setName("filemanager")
|
||||
begin
|
||||
while true
|
||||
@logger.info("top")
|
||||
@watching.each do |path, config|
|
||||
next if @file_threads[path]
|
||||
|
||||
|
@ -81,7 +80,7 @@ class LogStash::File::Manager
|
|||
"@tags" => config["tag"].dup,
|
||||
})
|
||||
e.source = "file://#{@hostname}/#{path}"
|
||||
@output_queue << e.dup
|
||||
@output_queue << e
|
||||
end # f.tail
|
||||
end # File.open
|
||||
end
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue