Redis Pubsub test

redis_test.rb

# Simple redis client to test pubsub
# All clients will send the current time to 'chan'
# and print out any messages they receive.
require 'rubygems'
require 'em-hiredis'

EventMachine.run do
  # Make $rl to listen
  $rl = EM::Hiredis.connect
  $rl.on(:message) do |channel, msg|
    puts "MESSAGE: #{channel} :: #{msg}"
  end
  $rl.subscribe 'chan'
  
  # Make $r to send messages
  $r = EM::Hiredis.connect
  EventMachine::PeriodicTimer.new(1) do
    # Dispatch message every second
    puts "TIMER -> dispatch"
    $r.publish 'chan', Time.now.utc.to_i.to_s
  end
end