## process_events.rb [ruby]

RAILS_HOME = File.expand_path(File.join(File.dirname(__FILE__),"../.."))
require RAILS_HOME + "/config/boot"
require "active_support"
require RAILS_HOME + "/config/environment"
require 'starling'
require 'daemons'

# TODO Needs to get config from external
@starling = Starling.new('127.0.0.1:22122')

def process_online_events
  logger.debug "test"
  items = {}
  @starling.flush('online_status') do |e|
    puts "item: #{e.inspect}"
    items[e[0]] = e[1]
  end
  Rails.cache.write('online_users', items)
  puts Rails.cache.read('online_users').inspect
end

Daemons.run_proc('process_online_events') do
  loop do
    process_online_events
    sleep 10
  end
end

## output [text]

dhaskin@dhaskin-desktop:~/workspace/bsg$ ruby lib/bsg/process_events.rb  run
/home/dhaskin/workspace/bsg/vendor/rails/activesupport/lib/active_support/buffered_logger.rb:105:in `write': closed stream (IOError)
	from /home/dhaskin/workspace/bsg/vendor/rails/activesupport/lib/active_support/buffered_logger.rb:105:in `flush'
	from /home/dhaskin/workspace/bsg/vendor/rails/activesupport/lib/active_support/buffered_logger.rb:118:in `auto_flush'
	from /home/dhaskin/workspace/bsg/vendor/rails/activesupport/lib/active_support/buffered_logger.rb:70:in `add'
	from /home/dhaskin/workspace/bsg/vendor/rails/activesupport/lib/active_support/buffered_logger.rb:76:in `debug'
	from lib/bsg/process_events.rb:12:in `process_online_events'
	from lib/bsg/process_events.rb:24
	from lib/bsg/process_events.rb:23:in `loop'
	from lib/bsg/process_events.rb:23
	 ... 7 levels...
	from /usr/lib/ruby/gems/1.8/gems/daemons-1.0.10/lib/daemons/cmdline.rb:105:in `call'
	from /usr/lib/ruby/gems/1.8/gems/daemons-1.0.10/lib/daemons/cmdline.rb:105:in `catch_exceptions'
	from /usr/lib/ruby/gems/1.8/gems/daemons-1.0.10/lib/daemons.rb:187:in `run_proc'
	from lib/bsg/process_events.rb:22