Method: LogStash::Outputs::WebSocket#receive

Defined in:
lib/logstash/outputs/websocket_topics.rb

#receive(event) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
 
# File 'lib/logstash/outputs/websocket_topics.rb', line 45

def receive(event)
  topic = event['topic']
  if @channels.has_key?(topic) 
    @channels[topic].publish(event.to_json)
  else
    pubsub = make_pubsub(topic) 
    @channels[topic] = pubsub
    pubsub.publish(event.to_json)
  end # if
end