mirror of
https://github.com/elastic/logstash.git
synced 2025-04-25 07:07:54 -04:00
- Add input logging
This commit is contained in:
parent
3c9c38e55e
commit
253df23b57
2 changed files with 2 additions and 0 deletions
|
@ -23,6 +23,7 @@ class LogStash::Inputs::Base
|
||||||
end
|
end
|
||||||
|
|
||||||
def receive(event)
|
def receive(event)
|
||||||
|
@logger.debug(["Got event", { :url => @url, :event => event }])
|
||||||
event.type = @type
|
event.type = @type
|
||||||
event.tags |= @tags # set union
|
event.tags |= @tags # set union
|
||||||
@callback.call(event)
|
@callback.call(event)
|
||||||
|
|
|
@ -23,6 +23,7 @@ class LogStash::Inputs::File < LogStash::Inputs::Base
|
||||||
"@type" => @type,
|
"@type" => @type,
|
||||||
"@tags" => @tags.clone,
|
"@tags" => @tags.clone,
|
||||||
})
|
})
|
||||||
|
@logger.debug(["Got event", event])
|
||||||
@callback.call(event)
|
@callback.call(event)
|
||||||
end # def event
|
end # def event
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue