lib/logstash/inputs/nsq.rb in logstash-input-nsq-1.0.2 vs lib/logstash/inputs/nsq.rb in logstash-input-nsq-1.0.3

- old
+ new

@@ -50,10 +50,10 @@ private def queue_event(body, output_queue) begin #@logger.info('processing:', :body => body) - event = LogStash::Event.new("message" => body, "host" => @host) + 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)