-

require 'redis'

$redis = Redis.new

def pub
  puts 'pub'
  $redis.publish('one', 'two')
  $redis.publish(:one, 'two')
  #$redis.publish(:one, 'exit')
end

def sub
  $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
end

t = Thread.new { sub }
Thread.new { pub }
t.join