Class: ActiveJob::QueueAdapters::SidekiqPublisherAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/active_job/queue_adapters/sidekiq_publisher_adapter.rb

Overview

To use SidekiqPublisher set the queue_adapter config to :sidekiq_publisher.

Rails.application.config.active_job.queue_adapter = :sidekiq_publisher

Constant Summary collapse

JOB_WRAPPER_CLASS = 
ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper.to_s.freeze

Instance Method Summary collapse

Instance Method Details

#enqueue(job) ⇒ Object 



13
14
15
16
17
18
19
 
# File 'lib/active_job/queue_adapters/sidekiq_publisher_adapter.rb', line 13

def enqueue(job)
  if SidekiqPublisher::DatabaseConnection.transaction_open?
    create_job_record(job)
  else
    sidekiq_adapter.enqueue(job)
  end
end

#enqueue_at(job, timestamp) ⇒ Object 



21
22
23
24
25
26
27
 
# File 'lib/active_job/queue_adapters/sidekiq_publisher_adapter.rb', line 21

def enqueue_at(job, timestamp)
  if SidekiqPublisher::DatabaseConnection.transaction_open?
    create_job_record(job, timestamp)
  else
    sidekiq_adapter.enqueue_at(job, timestamp)
  end
end