require 'rubygems'
 
# sudo gem install twitter-stream -s http://gemcutter.org
# http://github.com/voloko/twitter-stream
require 'twitter/json_stream'
 
token = 'xxx'
room_id = 111
 
options = {
  :path => "/room/#{room_id}/live.json",
  :host => 'streaming.campfirenow.com',
  :auth => "#{token}:x"
}
 
EventMachine::run do
  stream = Twitter::JSONStream.connect(options)
 
  stream.each_item do |item|
    puts item
  end
 
  stream.on_error do |message|
    puts "ERROR:#{message.inspect}"
  end
 
  stream.on_max_reconnects do |timeout, retries|
    puts "Tried #{retries} times to connect."
    exit
  end
end