Class: ActiveJob::QueueAdapters::SidekiqAdapter
- Inherits:
-
AbstractAdapter
- Object
- AbstractAdapter
- ActiveJob::QueueAdapters::SidekiqAdapter
- Defined in:
- activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb
Overview
Sidekiq adapter for Active Job
Simple, efficient background processing for Ruby. Sidekiq uses threads to handle many jobs at the same time in the same process. It does not require Rails but will integrate tightly with it to make background processing dead simple.
Read more about Sidekiq here.
To use Sidekiq set the queue_adapter config to :sidekiq
.
Rails.application.config.active_job.queue_adapter = :sidekiq
Defined Under Namespace
Classes: JobWrapper
Instance Attribute Summary
Attributes inherited from AbstractAdapter
Instance Method Summary collapse
-
#enqueue(job) ⇒ Object
:nodoc:.
-
#enqueue_all(jobs) ⇒ Object
:nodoc:.
-
#enqueue_at(job, timestamp) ⇒ Object
:nodoc:.
-
#initialize ⇒ SidekiqAdapter
constructor
:nodoc:.
Methods inherited from AbstractAdapter
Constructor Details
#initialize ⇒ SidekiqAdapter
:nodoc:
21 22 23 24 25 26 27 28 29 30 31 |
# File 'activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb', line 21 def initialize(*) # :nodoc: @stopping = false Sidekiq.configure_server do |config| config.on(:quiet) { @stopping = true } end Sidekiq.configure_client do |config| config.on(:quiet) { @stopping = true } end end |
Instance Method Details
#enqueue(job) ⇒ Object
:nodoc:
33 34 35 36 37 38 |
# File 'activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb', line 33 def enqueue(job) # :nodoc: job.provider_job_id = JobWrapper.set( wrapped: job.class, queue: job.queue_name ).perform_async(job.serialize) end |
#enqueue_all(jobs) ⇒ Object
:nodoc:
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 |
# File 'activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb', line 47 def enqueue_all(jobs) # :nodoc: enqueued_count = 0 jobs.group_by(&:class).each do |job_class, same_class_jobs| same_class_jobs.group_by(&:queue_name).each do |queue, same_class_and_queue_jobs| immediate_jobs, scheduled_jobs = same_class_and_queue_jobs.partition { |job| job.scheduled_at.nil? } if immediate_jobs.any? jids = Sidekiq::Client.push_bulk( "class" => JobWrapper, "wrapped" => job_class, "queue" => queue, "args" => immediate_jobs.map { |job| [job.serialize] }, ) enqueued_count += jids.compact.size end if scheduled_jobs.any? jids = Sidekiq::Client.push_bulk( "class" => JobWrapper, "wrapped" => job_class, "queue" => queue, "args" => scheduled_jobs.map { |job| [job.serialize] }, "at" => scheduled_jobs.map { |job| job.scheduled_at&.to_f } ) enqueued_count += jids.compact.size end end end enqueued_count end |
#enqueue_at(job, timestamp) ⇒ Object
:nodoc:
40 41 42 43 44 45 |
# File 'activejob/lib/active_job/queue_adapters/sidekiq_adapter.rb', line 40 def enqueue_at(job, ) # :nodoc: job.provider_job_id = JobWrapper.set( wrapped: job.class, queue: job.queue_name, ).perform_at(, job.serialize) end |