Subscription for the users timeline fetch

redis_subscribe.rb

require 'json'

redis = Redis.new

redis.subscribe(:vsagarv_channel) do |on|
  on.subscribe do |channel, subscriptions|
    puts "Subscribed to ##{channel} (#{subscriptions} subscriptions)"
  end

  on.message do |channel, message|
    puts "##{channel}: #{message}"
    message = JSON.parse(message)
    if(message['status'] == 'timeline_fetched')
      puts message['timeline_path']
      redis.unsubscribe
    end
  end
end