diff --git a/Gemfile.lock b/Gemfile.lock index 33b214ab..d57b822c 100644 --- a/Gemfile.lock +++ b/Gemfile.lock @@ -10,7 +10,7 @@ GIT GIT remote: https://github.com/basecamp/solid_queue - revision: 46f2d7eda5326551d44405b48a199125ce2157c4 + revision: d844a308e5c62b3d8f1942491c5433aca83dd2a9 specs: solid_queue (0.1.0) rails (>= 7.0.3.1) diff --git a/lib/active_job/queue_adapters/resque_ext.rb b/lib/active_job/queue_adapters/resque_ext.rb index 87133b59..abc60bd3 100644 --- a/lib/active_job/queue_adapters/resque_ext.rb +++ b/lib/active_job/queue_adapters/resque_ext.rb @@ -68,10 +68,6 @@ def support_class_name_filtering? false end - def support_pausing_queues? - true - end - def retry_all_jobs(jobs_relation) resque_jobs_for(jobs_relation).retry_all end diff --git a/lib/active_job/queue_adapters/solid_queue_ext.rb b/lib/active_job/queue_adapters/solid_queue_ext.rb index 113c835d..8bb93053 100644 --- a/lib/active_job/queue_adapters/solid_queue_ext.rb +++ b/lib/active_job/queue_adapters/solid_queue_ext.rb @@ -56,10 +56,6 @@ def support_class_name_filtering? true end - def support_pausing_queues? - false - end - def retry_all_jobs(jobs_relation) find_solid_queue_jobs_within(jobs_relation).each(&:retry) end diff --git a/test/active_job/queue_adapters/adapter_testing/queues.rb b/test/active_job/queue_adapters/adapter_testing/queues.rb index 52be3c6e..a68f9ea0 100644 --- a/test/active_job/queue_adapters/adapter_testing/queues.rb +++ b/test/active_job/queue_adapters/adapter_testing/queues.rb @@ -21,8 +21,6 @@ module ActiveJob::QueueAdapters::AdapterTesting::Queues end test "pause and resume queues" do - skip unless ActiveJob::Base.queue_adapter.support_pausing_queues? - create_queues "queue_1", "queue_2" queue = ApplicationJob.queues[:queue_1]