Class: LogStash::Outputs::WebSocket

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/websocket_topics.rb

Overview

This output runs a websocket server and publishes any messages to all connected websocket clients.

You can connect to it with ws://<host>:<port>/

If no clients are connected, any messages received are ignored.

Instance Method Summary collapse

Instance Method Details

#receive(event) ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/logstash/outputs/websocket_topics.rb', line 39

def receive(event)
  topic = event['topic']
  json = JSON.generate(event)
  if @channels.has_key?(topic) 
    @channels[topic].publish(json)
  else
    require "logstash/outputs/websocket_topics/pubsub"
    pubsub = LogStash::Outputs::WebSocket::Pubsub.new
    pubsub.logger = @logger
    @channels[topic] = pubsub
    pubsub.publish(json)
  end # if
end

#register ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/logstash/outputs/websocket_topics.rb', line 22

def register
  require "ftw"
  require "logstash/outputs/websocket_topics/app"
  @channels = {}
  @server = Thread.new(@channels) do |channels|
    begin
      Rack::Handler::FTW.run(LogStash::Outputs::WebSocket::App.new(channels, @logger),
                             :Host => @host, :Port => @port)
    rescue => e
      @logger.error("websocket server failed", :exception => e)
      sleep 1
      retry
    end
  end
end