- Add websocket support (not yet tested)

lib/outputs/websocket.rb

@@ -0,0 +1,35 @@
+require "logstash/namespace"
+require "logstash/event"
+require "uri"
+require "em-websocket" # rubygem 'em-websocket'
+
+class LogStash::Outputs::Websocket
+  def initialize(url, config={}, &block)
+    @url = url
+    @url = URI.parse(url) if url.is_a? String
+    @config = config
+  end
+
+  def register
+    puts "register"
+    @channel = EventMachine::Channel.new
+    host = (@url.host or "0.0.0.0")
+    port = (@url.port or 3000)
+    EventMachine::WebSocket.start(:host => host, :port => port) do |ws|
+      ws.onopen do
+        puts "Open"
+        sid = @channel.subscribe do |msg| 
+          puts "Sending: #{msg}"
+          ws.send msg
+        end
+        ws.onclose do
+          @channel.unsubscribe(sid)
+        end # ws.onclose
+      end # ws.onopen
+    end
+  end # def register
+
+  def receive(event)
+    @channel.push event.to_json
+  end # def event
+end # class LogStash::Outputs::Websocket