github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Uses to_event to parse msg in redis input.

Browse source
This commit is contained in:
Bob Corsaro 2011-05-30 22:06:11 -04:00
parent 58664a3734
commit 89de858d3a
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
lib/logstash/inputs/redis.rb
View file

@ -32,8 +32,7 @@ class LogStash::Inputs::Redis < LogStash::Inputs::Base
# TODO: remove
config :queue, :validate => :string, :deprecated => true
# The name of a redis list or channel. Dynamic names are
# valid here, for example "logstash-%{@type}".
# The name of a redis list or channel.
# TODO: change required to true
config :key, :validate => :string, :required => false
@ -96,8 +95,8 @@ class LogStash::Inputs::Redis < LogStash::Inputs::Base
private
def queue_event msg, output_queue
begin
e = LogStash::Event.new(JSON.parse(msg))
output_queue << e if e
event = to_event msg, identity
output_queue << event if event
rescue => e # parse or event creation error
@logger.error(["Failed to create event with '#{msg}'", e])
@logger.debug(["Backtrace", e.backtrace])