lib/logstash/outputs/websocket_topics.rb in logstash-output-websocket_topics-2.1.5 vs lib/logstash/outputs/websocket_topics.rb in logstash-output-websocket_topics-2.1.6

@@ -41,10 +41,10 @@
     end
   end # def register
 
   public
   def receive(event)
-    topic = event.topic
+    topic = event['topic']
     if @channels.has_key?(topic) 
       @channels[topic].publish(event.to_json)
     else
       pubsub = make_pubsub(topic) 
       @channels[topic] = pubsub