Class: ActiveJob::QueueAdapters::QueueClassicAdapter
| Relationships & Source Files | |
| Super Chains via Extension / Inclusion / Inheritance | |
| Class Chain: 
          self,
           AbstractAdapter | |
| Instance Chain: 
          self,
           AbstractAdapter | |
| Inherits: | ActiveJob::QueueAdapters::AbstractAdapter 
 | 
| Defined in: | activejob/lib/active_job/queue_adapters/queue_classic_adapter.rb | 
Overview
queue_classic adapter for Active Job
queue_classic provides a simple interface to a PostgreSQL-backed message queue. queue_classic specializes in concurrent locking and minimizing database load while providing a simple, intuitive developer experience. queue_classic assumes that you are already using PostgreSQL in your production environment and that adding another dependency (e.g. redis, beanstalkd, 0mq) is undesirable.
Read more about queue_classic here.
To use queue_classic set the queue_adapter config to :queue_classic.
Rails.application.config.active_job.queue_adapter = :queue_classicClass Method Summary
Instance Attribute Summary
AbstractAdapter - Inherited
| #enqueue_after_transaction_commit? | Defines whether enqueuing should happen implicitly to after commit when called from inside a transaction. | 
Instance Method Summary
- 
    
      #build_queue(queue_name)  
    
    Builds a QC::Queueobject to schedule jobs on.
AbstractAdapter - Inherited
Constructor Details
    .new(enqueue_after_transaction_commit: false)  ⇒ QueueClassicAdapter 
  
# File 'activejob/lib/active_job/queue_adapters/queue_classic_adapter.rb', line 22
def initialize(enqueue_after_transaction_commit: false) @enqueue_after_transaction_commit = enqueue_after_transaction_commit end
Instance Method Details
#build_queue(queue_name)
Builds a QC::Queue object to schedule jobs on.
If you have a custom QC::Queue subclass you’ll need to subclass QueueClassicAdapter and override the build_queue method.
# File 'activejob/lib/active_job/queue_adapters/queue_classic_adapter.rb', line 53
def build_queue(queue_name) QC::Queue.new(queue_name) end