mirror of
https://github.com/elastic/logstash.git
synced 2025-04-23 22:27:21 -04:00
style fix
This commit is contained in:
parent
6ebe1e4f0e
commit
fe06a4ba54
1 changed files with 2 additions and 2 deletions
|
@ -14,7 +14,7 @@ class LogStash::Inputs::File < LogStash::Inputs::Base
|
|||
def register
|
||||
EventMachine::FileGlobWatchTail.new(@url.path, Reader, interval=60,
|
||||
exclude=[], receiver=self)
|
||||
end
|
||||
end # def register
|
||||
|
||||
def receive(filetail, event)
|
||||
url = @url.clone
|
||||
|
@ -28,7 +28,7 @@ class LogStash::Inputs::File < LogStash::Inputs::Base
|
|||
})
|
||||
@logger.debug(["Got event", event])
|
||||
@callback.call(event)
|
||||
end # def event
|
||||
end # def receive
|
||||
|
||||
class Reader < EventMachine::FileTail
|
||||
def initialize(path, receiver)
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue