lib/qe/sidekiq.rb in qe-0.2.0 vs lib/qe/sidekiq.rb in qe-0.2.1

- old
+ new

@@ -13,9 +13,14 @@ def self.enqueue(worker, options = {}) Worker.sidekiq_options :queue => worker.queue Worker.perform_async(worker.name, options) end + + def self.schedule(worker, run_at, options = {}) + Worker.sidekiq_options :queue => worker.queue + Worker.perform_at(run_at, worker.name, options) + end end self.adapter = Sidekiq end