xmpp.rb in logstash-input-xmpp-3.0.0

- old
+ new

@@ -60,12 +60,12 @@
         muc = Jabber::MUC::SimpleMUCClient.new(client)
         muc.join(room)
         muc.on_message do |time, from, body|
           @codec.decode(body) do |event|
             decorate(event)
-            event["room"] = room
-            event["from"] = from
+            event.set("room", room)
+            event.set("from", from)
             queue << event
           end
         end # @muc.on_message
         # we need to hold a reference to the muc
         # otherwise it will be GC'd
@@ -78,10 +78,10 @@
       if msg.body != nil
         @codec.decode(msg.body) do |event|
           decorate(event)
           # Maybe "from" should just be a hash:
           # { "node" => ..., "domain" => ..., "resource" => ... }
-          event["from"] = "#{msg.from.node}@#{msg.from.domain}/#{msg.from.resource}"
+          event.set("from", "#{msg.from.node}@#{msg.from.domain}/#{msg.from.resource}")
           queue << event
         end
       end
     end # @client.add_message_callback
 