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)
    item['class'] = constantize(item['class']) # Sidekiq expects the class to be constantized.
    Sidekiq::Client.push(item)
  end
  Sidekiq::Client.remove_scheduler_queue(timestamp)
end