diff options
Diffstat (limited to 'lib/active_job/queue_adapters/resque_adapter.rb')
-rw-r--r-- | lib/active_job/queue_adapters/resque_adapter.rb | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/lib/active_job/queue_adapters/resque_adapter.rb b/lib/active_job/queue_adapters/resque_adapter.rb index f7ed4669bd..84904f84f2 100644 --- a/lib/active_job/queue_adapters/resque_adapter.rb +++ b/lib/active_job/queue_adapters/resque_adapter.rb @@ -8,11 +8,11 @@ module ActiveJob class ResqueAdapter class << self def enqueue(job, *args) - Resque.enqueue JobWrapper.new(job), job, *args + Resque.enqueue_to job.queue_name, JobWrapper, job.name, *args end def enqueue_at(job, timestamp, *args) - Resque.enqueue_at timestamp, JobWrapper.new(job), job, *args + Resque.enqueue_at_with_queue job.queue_name, timestamp, JobWrapper, job.name, *args end end @@ -22,14 +22,6 @@ module ActiveJob job_name.constantize.new.execute *args end end - - def initialize(job) - @queue = job.queue_name - end - - def to_s - self.class.name - end end end end |