aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/queue_adapters/sidekiq_adapter.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/active_job/queue_adapters/sidekiq_adapter.rb')
-rw-r--r--lib/active_job/queue_adapters/sidekiq_adapter.rb9
1 files changed, 9 insertions, 0 deletions
diff --git a/lib/active_job/queue_adapters/sidekiq_adapter.rb b/lib/active_job/queue_adapters/sidekiq_adapter.rb
index 43bd69790c..be6bd4ee01 100644
--- a/lib/active_job/queue_adapters/sidekiq_adapter.rb
+++ b/lib/active_job/queue_adapters/sidekiq_adapter.rb
@@ -11,6 +11,15 @@ module ActiveJob
'args' => [ job, *args ],
'retry' => true
end
+
+ def queue_at(job, timestamp, *args)
+ Sidekiq::Client.push \
+ 'class' => JobWrapper,
+ 'queue' => job.queue_name,
+ 'args' => [ job, *args ],
+ 'at' => timestamp,
+ 'retry' => true
+ end
end
class JobWrapper