diff options
| author | Rafael Mendonça França <rafaelmfranca@gmail.com> | 2016-08-23 00:38:42 -0300 |
|---|---|---|
| committer | Rafael Mendonça França <rafaelmfranca@gmail.com> | 2016-08-23 00:39:39 -0300 |
| commit | 7f4b16ed83b878df6a68d471d2d5e7c719b40261 (patch) | |
| tree | f290d32680e741631e65af5e67d07559209f81b2 /activejob/lib/active_job | |
| parent | 97507329d6248fa7ade24ff540c3637010bdb6c7 (diff) | |
| parent | 9f6461a28cb5241b478884e84882cca8a0897cda (diff) | |
| download | rails-7f4b16ed83b878df6a68d471d2d5e7c719b40261.tar.gz rails-7f4b16ed83b878df6a68d471d2d5e7c719b40261.tar.bz2 rails-7f4b16ed83b878df6a68d471d2d5e7c719b40261.zip | |
Merge pull request #26205 from pedaling-corp/fix/active-job-resque
Add @queue variable to JobWrapper
Diffstat (limited to 'activejob/lib/active_job')
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/resque_adapter.rb | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/activejob/lib/active_job/queue_adapters/resque_adapter.rb b/activejob/lib/active_job/queue_adapters/resque_adapter.rb index 8620401cc1..2df157ef89 100644 --- a/activejob/lib/active_job/queue_adapters/resque_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/resque_adapter.rb @@ -27,6 +27,7 @@ module ActiveJob # Rails.application.config.active_job.queue_adapter = :resque class ResqueAdapter def enqueue(job) #:nodoc: + JobWrapper.instance_variable_set(:@queue, job.queue_name) Resque.enqueue_to job.queue_name, JobWrapper, job.serialize end |