diff options
author | Gabi Stefanini <gabriela.stefanini@shopify.com> | 2016-10-19 01:54:26 -0400 |
---|---|---|
committer | Gabi Stefanini <gabriela.stefanini@shopify.com> | 2016-10-21 11:59:01 -0400 |
commit | 0d454d08061e183064c8148d313dbf05cab8c23b (patch) | |
tree | cf794fb950bcab47ac84a13490fd96a3d1c3ddb1 /activejob | |
parent | 4393406a8ac0d3c616210a96bca81dd6a12bf881 (diff) | |
download | rails-0d454d08061e183064c8148d313dbf05cab8c23b.tar.gz rails-0d454d08061e183064c8148d313dbf05cab8c23b.tar.bz2 rails-0d454d08061e183064c8148d313dbf05cab8c23b.zip |
Add examples of queue_adapter and perform_enqueued jobs to API Docs.
Diffstat (limited to 'activejob')
-rw-r--r-- | activejob/lib/active_job/test_helper.rb | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/activejob/lib/active_job/test_helper.rb b/activejob/lib/active_job/test_helper.rb index bbd2a0c06c..1a8b3375ae 100644 --- a/activejob/lib/active_job/test_helper.rb +++ b/activejob/lib/active_job/test_helper.rb @@ -269,6 +269,25 @@ module ActiveJob instantiate_job(matching_job) end + # Performs all enqueued jobs in the duration of the block. + # + # def test_perform_enqueued_jobs + # perform_enqueued_jobs do + # MyJob.perform_later(1, 2, 3) + # end + # assert_performed_jobs 1 + # end + # + # This method also supports filtering. If the +:only+ option is specified, + # then only the listed job(s) will be performed. + # + # def test_perform_enqueued_jobs_with_only + # perform_enqueued_jobs(only: MyJob) do + # MyJob.perform_later(1, 2, 3) # will be performed + # HelloJob.perform_later(1, 2, 3) # will not be perfomed + # end + # assert_performed_jobs 1 + # end def perform_enqueued_jobs(only: nil) old_perform_enqueued_jobs = queue_adapter.perform_enqueued_jobs old_perform_enqueued_at_jobs = queue_adapter.perform_enqueued_at_jobs @@ -286,6 +305,11 @@ module ActiveJob end end + # Accesses the queue_adapter set by ActiveJob::Base. + # + # def test_assert_job_has_custom_queue_adapter_set + # assert_instance_of CustomQueueAdapter, HelloJob.queue_adapter + # end def queue_adapter ActiveJob::Base.queue_adapter end |