diff options
author | Mike Perham <mperham@gmail.com> | 2014-05-19 15:27:28 -0700 |
---|---|---|
committer | Mike Perham <mperham@gmail.com> | 2014-05-19 15:27:28 -0700 |
commit | 3648838173a1d7217560ed1cf8ab2a217ccbc6d1 (patch) | |
tree | 54f1fdc31dd091cc81652bb7acd2d42fd5b2cdcc /lib/active_job/queue_adapters/resque_adapter.rb | |
parent | c6925f52d07a01c2b729a70bac60b11f7e514d76 (diff) | |
download | rails-3648838173a1d7217560ed1cf8ab2a217ccbc6d1.tar.gz rails-3648838173a1d7217560ed1cf8ab2a217ccbc6d1.tar.bz2 rails-3648838173a1d7217560ed1cf8ab2a217ccbc6d1.zip |
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.
Diffstat (limited to 'lib/active_job/queue_adapters/resque_adapter.rb')
-rw-r--r-- | lib/active_job/queue_adapters/resque_adapter.rb | 6 |
1 files changed, 6 insertions, 0 deletions
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 |