Sha256: d9a7be95fb7d356b01e0e0a3b56aa83b9547c63ee2e859056c56c576c62e0efb
Contents?: true
Size: 1.31 KB
Versions: 4
Compression:
Stored size: 1.31 KB
Contents
# encoding: utf-8
require "logstash/namespace"
require "logstash/outputs/base"
# 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.
class LogStash::Outputs::WebSocket < LogStash::Outputs::Base
config_name "websocket"
# The address to serve websocket data from
config :host, :validate => :string, :default => "0.0.0.0"
# The port to serve websocket data from
config :port, :validate => :number, :default => 3232
public
def register
require "ftw"
require "logstash/outputs/websocket/app"
require "logstash/outputs/websocket/pubsub"
@pubsub = LogStash::Outputs::WebSocket::Pubsub.new
@pubsub.logger = @logger
@server = Thread.new(@pubsub) do |pubsub|
begin
Rack::Handler::FTW.run(LogStash::Outputs::WebSocket::App.new(pubsub, @logger),
:Host => @host, :Port => @port)
rescue => e
@logger.error("websocket server failed", :exception => e)
sleep 1
retry
end
end
end # def register
public
def receive(event)
return unless output?(event)
@pubsub.publish(event.to_json)
end # def receive
end # class LogStash::Outputs::Websocket
Version data entries
4 entries across 4 versions & 1 rubygems