diff options
author | Rafael França <rafaelmfranca@gmail.com> | 2016-10-21 13:56:39 -0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-10-21 13:56:39 -0300 |
commit | 2b584f165bc919c5e698e52d84c582a2f5f22b35 (patch) | |
tree | ed69f57b4b88fb4daa5ec3f3bc517b0f8bbf80db | |
parent | 0aed0bbb2956e3607a1a15d260a0833d4d3a7aa0 (diff) | |
parent | 0d454d08061e183064c8148d313dbf05cab8c23b (diff) | |
download | rails-2b584f165bc919c5e698e52d84c582a2f5f22b35.tar.gz rails-2b584f165bc919c5e698e52d84c582a2f5f22b35.tar.bz2 rails-2b584f165bc919c5e698e52d84c582a2f5f22b35.zip |
Merge pull request #26819 from lastgabs/add-examples-active-job-test-helper
Add examples of queue_adapter and perform_enqueued jobs to API Docs.
-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 |