class SidekiqScheduler::Manager

def find_scheduled_work(timestamp)
  loop do
    break logger.debug("Finished processing queue for timestamp #{timestamp}") unless msg = redis { |r| r.lpop("delayed:#{timestamp}") }
    item = MultiJson.decode(msg)
    queue = item.delete('queue')
    Sidekiq::Client.push(queue, item)
  end
  Sidekiq::Client.remove_scheduler_queue(timestamp)
end