Skip to content

Instantly share code, notes, and snippets.

@rubenfonseca
Created December 27, 2009 23:43
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save rubenfonseca/264453 to your computer and use it in GitHub Desktop.
Save rubenfonseca/264453 to your computer and use it in GitHub Desktop.
require 'em-websocket'
require 'uuid'
require 'mq'
uuid = UUID.new
EventMachine::WebSocket.start(:host => "0.0.0.0", :port => 8080) do |ws|
ws.onopen do
puts "WebSocket opened"
twitter = MQ.new
twitter.queue(uuid.generate).bind(twitter.fanout('twitter')).subscribe do |t|
ws.send t
end
end
ws.onclose do
puts "WebSocket closed"
end
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment