lib/logstash/outputs/websocket_topics.rb in logstash-output-websocket_topics-2.1.7 vs lib/logstash/outputs/websocket_topics.rb in logstash-output-websocket_topics-2.1.8
- old
+ new
@@ -24,11 +24,11 @@
end
public
def register
require "ftw"
- require "logstash/outputs/websocket_topics/app"
- require "logstash/outputs/websocket_topics/pubsub"
+ 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)