class Rufus::Scheduler::SchedulerCore

def get_queue(type, opts)
  q = if type == :cron
    opts[:cron_job_queue] || Rufus::Scheduler::CronJobQueue.new
  else
    opts[:job_queue] || Rufus::Scheduler::JobQueue.new
  end
  q.scheduler = self if q.respond_to?(:scheduler=)
  q
end