redis expiration listener

gistfile1.txt

def start_listener()
  uri = URI.parse(ENV["REDISCLOUD_URL"])
  redis = Redis.new(host: uri.host, port: uri.port, password: uri.password)
  Thread.new do
    begin
      redis.subscribe("__keyevent@0__:expired") do |on|
        on.subscribe do |channel, subscriptions|
          puts "Subscribed to ##{channel} (#{subscriptions} subscriptions)"
        end

        on.message do |channel, message|
          puts "got a message"
          do_something()
          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
    ensure
      #no db connection anyway
    end
  end
end