flaviokr · August 11, 2020 22:43
diff --git a/move_sidekiq_jobs_between_queues.rb b/move_sidekiq_jobs_between_queues.rb
 # para mover da fila low para pending
 q_from = "low"
 q_to = "pending"
 count_block = proc{ Sidekiq.redis { |conn| conn.llen("queue:#{q_from}") } }
 while count_block.call > 0 do
  Sidekiq.redis { |conn| conn.rpoplpush "queue:#{q_from}", "queue:#{q_to}" }
 end
  
 # para recuperar os jobs da fila pending
 # verificar se todos os jobs são da mesma classe
 Redis.new.lrange('playax:queue:pending', 0, -1).each do |job|
  job = JSON.parse(job)
  <Worker>.perform_async(job['args'].first)
 end
	# para mover da fila low para pending
	q_from = "low"
	q_to = "pending"
	count_block = proc{ Sidekiq.redis { \|conn\| conn.llen("queue:#{q_from}") } }
	while count_block.call > 0 do
	Sidekiq.redis { \|conn\| conn.rpoplpush "queue:#{q_from}", "queue:#{q_to}" }
	end

	# para recuperar os jobs da fila pending
	# verificar se todos os jobs são da mesma classe
	Redis.new.lrange('playax:queue:pending', 0, -1).each do \|job\|
	job = JSON.parse(job)
	<Worker>.perform_async(job['args'].first)
	end