Method: LogStash::Outputs::WebSocket#register

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

#register ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/logstash/outputs/websocket_topics.rb', line 27

def register
  require "ftw"
  require "logstash/outputs/websocket/app"
  require "logstash/outputs/websocket/pubsub"
  @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