redis-pubsub.rb

require "redis"

@redis = Redis.new(:timeout => 0)

@redis.subscribe('a', 'b') do |on|
  on.subscribe do |klass, num_subs|
    puts "Subscribed to #{klass} (#{num_subs} subscriptions)"
  end
  on.message do |klass, msg|
    puts "#{klass} received: #{msg}"
    if msg == 'exit'
      @redis.unsubscribe
    end
  end
  on.unsubscribe do |klass, num_subs|
    puts "Unsubscribed from #{klass} (#{num_subs} subscriptions)" 
  end
end