Sha256: e238ee5951666607bd5fe3e4e71b32852ed787864446d38674dfbb3ce3519729
Contents?: true
Size: 822 Bytes
Versions: 35
Compression:
Stored size: 822 Bytes
Contents
require "redis"
puts <<-EOS
To play with this example use redis-cli from another terminal, like this:
$ redis-cli publish one hello
Finally force the example to exit sending the 'exit' message with:
$ redis-cli publish two exit
EOS
redis = Redis.new
trap(:INT) { puts; exit }
begin
redis.subscribe(:one, :two) do |on|
on.subscribe do |channel, subscriptions|
puts "Subscribed to ##{channel} (#{subscriptions} subscriptions)"
end
on.message do |channel, message|
puts "##{channel}: #{message}"
redis.unsubscribe if message == "exit"
end
on.unsubscribe do |channel, subscriptions|
puts "Unsubscribed from ##{channel} (#{subscriptions} subscriptions)"
end
end
rescue Redis::BaseConnectionError => error
puts "#{error}, retrying in 1s"
sleep 1
retry
end
Version data entries
35 entries across 34 versions & 9 rubygems