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

Version	Path
discourse-redis-3.2.2	examples/pubsub.rb
redis-3.2.2	examples/pubsub.rb
redis-3.2.1	examples/pubsub.rb
redis-3.2.0	examples/pubsub.rb
redis-3.1.0	examples/pubsub.rb
redis-3.0.7	examples/pubsub.rb
redis-3.0.6	examples/pubsub.rb
redis-3.0.5	examples/pubsub.rb
sidekiq-statsd-0.1.1	vendor/ruby/1.9.1/gems/redis-3.0.4/examples/pubsub.rb
sidekiq-statsd-0.1.0	vendor/ruby/1.9.1/gems/redis-3.0.4/examples/pubsub.rb
redis-3.0.4	examples/pubsub.rb
redis-3.0.3	examples/pubsub.rb
remq-0.0.4	vendor/bundle/gems/redis-3.0.2/examples/pubsub.rb
remq-0.0.3	vendor/bundle/gems/redis-3.0.2/examples/pubsub.rb
redis-3.0.2	examples/pubsub.rb