fixing gelf output for deprecated usage

This commit is contained in:
John E. Vincent 2011-03-31 13:11:35 -04:00
parent 8a6935b3ec
commit 39377a4258

View file

@ -20,18 +20,19 @@ class LogStash::Outputs::Gelf < LogStash::Outputs::Base
public
def receive(event)
# TODO(sissel): Use Gelf::Message instead
gelf = Gelf.new(@url.host, (@url.port or 12201))
gelf.short_message = (event.fields["message"] or event.message)
gelf.full_message = (event.message)
gelf.level = 1
gelf.host = event["@source_host"]
gelf.file = event["@source_path"]
gelf = GELF::Notifier.new(@url.host, (@url.port or 12201))
m = Hash.new
m["short_message"] = (event.fields["message"] or event.message)
m["full_message"] = (event.message)
m["host"] = event["@source_host"]
m["file"] = event["@source_path"]
m["level"] = 1
event.fields.each do |name, value|
next if value == nil or value.empty?
gelf.add_additional name, value
m["#{name}"] = value
end
gelf.add_additional "event_timestamp", event.timestamp
gelf.send
m["timestamp"] = event.timestamp
gelf.notify(m)
end # def receive
end # class LogStash::Outputs::Gelf