diff options
| author | David Heinemeier Hansson <david@basecamp.com> | 2014-05-20 12:09:24 +0200 |
|---|---|---|
| committer | David Heinemeier Hansson <david@basecamp.com> | 2014-05-20 12:09:24 +0200 |
| commit | 7a6aa47757319fb1da6b60f820199cd6082fe8b7 (patch) | |
| tree | 8dcdc5cffe9abfd787d78158a7ab7e2b7e53615f /lib/active_job | |
| parent | 9c8c6bf4390a60be15fa69dfdd682f82e8639bc7 (diff) | |
| parent | 6d009504a02fecb822820e18abd69dd569f72e82 (diff) | |
| download | rails-7a6aa47757319fb1da6b60f820199cd6082fe8b7.tar.gz rails-7a6aa47757319fb1da6b60f820199cd6082fe8b7.tar.bz2 rails-7a6aa47757319fb1da6b60f820199cd6082fe8b7.zip | |
Merge pull request #31 from seuros/master
Add Que Adapter/Wrapper
Diffstat (limited to 'lib/active_job')
| -rw-r--r-- | lib/active_job/queue_adapters/que_adapter.rb | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/lib/active_job/queue_adapters/que_adapter.rb b/lib/active_job/queue_adapters/que_adapter.rb new file mode 100644 index 0000000000..6750882b91 --- /dev/null +++ b/lib/active_job/queue_adapters/que_adapter.rb @@ -0,0 +1,19 @@ +require 'que' + +module ActiveJob + module QueueAdapters + class QueAdapter + class << self + def queue(job, *args) + JobWrapper.enqueue job, *args, queue: job.queue_name + end + end + + class JobWrapper < Que::Job + def run(job, *args) + job.new.perform *Parameters.deserialize(args) + end + end + end + end +end |