github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-23 22:27:21 -04:00
Code Issues Projects Releases Packages Wiki Activity

- Set source url with the accessor, not from the hash.

Browse source
This commit is contained in:
Jordan Sissel 2010-11-18 13:44:34 -08:00
parent 9c68e35548
commit 1b65bcc310
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/logstash/inputs/file.rb
View file

@ -21,11 +21,11 @@ class LogStash::Inputs::File < LogStash::Inputs::Base
url.path = filetail.path
@logger.debug(["original url", { :originalurl => @url, :newurl => url }])
event = LogStash::Event.new({
"@source" => url,
"@message" => event,
"@type" => @type,
"@tags" => @tags.clone,
})
event.source = url
@logger.debug(["Got event", event])
@callback.call(event)
end # def receive

2
lib/logstash/inputs/tcp.rb
View file

@ -24,11 +24,11 @@ class LogStash::Inputs::Tcp < LogStash::Inputs::Base
url.port = port
@logger.debug(["original url", { :originalurl => @url, :newurl => url }])
event = LogStash::Event.new({
"@source" => url,
"@message" => event,
"@type" => @type,
"@tags" => @tags.clone,
})
event.source = url
@logger.debug(["Got event", event])
@callback.call(event)
end # def receive