From 3648838173a1d7217560ed1cf8ab2a217ccbc6d1 Mon Sep 17 00:00:00 2001 From: Mike Perham Date: Mon, 19 May 2014 15:27:28 -0700 Subject: Implement enqueue_at/enqueue_in Delayed jobs are supported by all systems except QueueClassic. For it I decided to raise NotImplementedError. The inline implementation is a bit rough. --- lib/active_job/queue_adapters/resque_adapter.rb | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'lib/active_job/queue_adapters/resque_adapter.rb') diff --git a/lib/active_job/queue_adapters/resque_adapter.rb b/lib/active_job/queue_adapters/resque_adapter.rb index 6686f10593..8fa8dddd11 100644 --- a/lib/active_job/queue_adapters/resque_adapter.rb +++ b/lib/active_job/queue_adapters/resque_adapter.rb @@ -1,6 +1,7 @@ require 'resque' require 'active_support/core_ext/enumerable' require 'active_support/core_ext/array/access' +require 'resque_scheduler' module ActiveJob module QueueAdapters @@ -9,6 +10,11 @@ module ActiveJob def queue(job, *args) Resque.enqueue JobWrapper.new(job), job, *args end + + def queue_at(job, timestamp, *args) + # requires resque-scheduler + Resque.enqueue_at timestamp, JobWrapper.new(job), job, *args + end end class JobWrapper -- cgit v1.2.3