lib/logstash/inputs/nsq.rb in logstash-input-nsq-2.0.0 vs lib/logstash/inputs/nsq.rb in logstash-input-nsq-2.0.1
- old
+ new
@@ -48,22 +48,22 @@
while !stop?
#@logger.info('consuming...')
event = @consumer.pop
#@logger.info('processing:', :event => event)
queue_event(event.body, logstash_queue)
- event.finish
+ event.finish
end
@logger.warn('Done running nsq input')
end
end # def run
private
def queue_event(body, output_queue)
begin
#@logger.info('processing:', :body => body)
- event = LogStash::Event.new("message" => body)
- decorate(event)
- output_queue << event
+ event = LogStash::Event.new("message" => body)
+ decorate(event)
+ output_queue << event
rescue => e # parse or event creation error
@logger.error('Failed to create event', :message => "#{body}", :exception => e,
:backtrace => e.backtrace)
end # begin
end # def queue_event