class SidekiqScheduler::Manager
from Redis onto the work queues
manages the scheduled jobs pushed messages
The delayed job router in the system. This
def initialize(options={})
def initialize(options={}) @enabled = options[:scheduler] Sidekiq::Scheduler.dynamic = options[:dynamic] || false Sidekiq.schedule = options[:schedule] if options[:schedule] end
def reset
def reset clear_scheduled_work end
def start
def start # Load the schedule into rufus # If dynamic is set, load that schedule otherwise use normal load if @enabled && Sidekiq::Scheduler.dynamic Sidekiq::Scheduler.reload_schedule! elsif @enabled Sidekiq::Scheduler.load_schedule! end end
def stop
def stop @enabled = false end