lib/logstash/inputs/pipe.rb in logstash-input-pipe-2.0.4 vs lib/logstash/inputs/pipe.rb in logstash-input-pipe-3.0.0

@@ -46,11 +46,11 @@
 
         @pipe.each do |line|
           line = line.chomp
           @logger.debug? && @logger.debug("Received line", :command => @command, :line => line)
           @codec.decode(line) do |event|
-            event["host"] = hostname
-            event["command"] = @command
+            event.set("host", hostname)
+            event.set("command", @command)
             decorate(event)
             queue << event
           end
         end
         @pipe.close