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)