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