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