diff options
author | Cristian Bica <cristian.bica@gmail.com> | 2014-08-25 17:34:50 +0300 |
---|---|---|
committer | Cristian Bica <cristian.bica@gmail.com> | 2014-09-03 23:01:46 +0300 |
commit | 1e237b4e44b7de564c7d6b331dd2f2243c4113fd (patch) | |
tree | c272b813a4968815026d86f6b47ab9839ce3ab03 /guides/source | |
parent | 5db4e7f0ec2957f8641d5af884bd39e31d795597 (diff) | |
download | rails-1e237b4e44b7de564c7d6b331dd2f2243c4113fd.tar.gz rails-1e237b4e44b7de564c7d6b331dd2f2243c4113fd.tar.bz2 rails-1e237b4e44b7de564c7d6b331dd2f2243c4113fd.zip |
Active Job refactoring
Diffstat (limited to 'guides/source')
-rw-r--r-- | guides/source/active_job_basics.md | 44 |
1 files changed, 38 insertions, 6 deletions
diff --git a/guides/source/active_job_basics.md b/guides/source/active_job_basics.md index 2c6e79a5b0..7b3081993d 100644 --- a/guides/source/active_job_basics.md +++ b/guides/source/active_job_basics.md @@ -78,15 +78,15 @@ end Enqueue a job like so: ```ruby -MyJob.enqueue record # Enqueue a job to be performed as soon the queueing system is free. +MyJob.perform_later record # Enqueue a job to be performed as soon the queueing system is free. ``` ```ruby -MyJob.enqueue_at Date.tomorrow.noon, record # Enqueue a job to be performed tomorrow at noon. +MyJob.set(wait_until: Date.tomorrow.noon).perform_later(record) # Enqueue a job to be performed tomorrow at noon. ``` ```ruby -MyJob.enqueue_in 1.week, record # Enqueue a job to be performed 1 week from now. +MyJob.set(wait: 1.week).perform_later(record) # Enqueue a job to be performed 1 week from now. ``` That's it! @@ -155,7 +155,7 @@ class GuestsCleanupJob < ActiveJob::Base end ``` -Also you can prefix the queue name for all your jobs using +You can prefix the queue name for all your jobs using `config.active_job.queue_name_prefix` in `application.rb`: ```ruby @@ -172,10 +172,42 @@ class GuestsCleanupJob < ActiveJob::Base #.... end -# Now your job will run on queue production_low_priority on your production -# environment and on beta_low_priority on your beta environment +# Now your job will run on queue production_low_priority on your +# production environment and on beta_low_priority on your beta +# environment ``` +If you want more control on what queue a job will be run you can pass a :queue +option to #set: + +```ruby +MyJob.set(queue: :another_queue).perform_later(record) +``` + +To control the queue from the job level you can pass a block to queue_as. The +block will be executed in the job context (so you can access self.arguments) +and you must return the queue name: + +```ruby +class ProcessVideoJob < ActiveJob::Base + queue_as do + video = self.arguments.first + if video.owner.premium? + :premium_videojobs + else + :videojobs + end + end + + def perform(video) + # do process video + end +end + +ProcessVideoJob.perform_later(Video.last) +``` + + NOTE: Make sure your queueing backend "listens" on your queue name. For some backends you need to specify the queues to listen to. |