Class: ActiveJob::QueueAdapters::PikaQueRails4

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

Overview

PikaQue adapter for Active Job

PikaQue is a RabbitMQ background processing framework for Ruby.

Read more about PikaQue here.

To use PikaQue set the queue_adapter config to :pika_que.

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

Defined Under Namespace

Classes: JobWrapper

Class Method Summary collapse

Class Method Details

.enqueue(job) ⇒ Object

:nodoc:



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

def enqueue(job) #:nodoc:
  @monitor.synchronize do
    JobWrapper.enqueue job.serialize, to_queue: job.queue_name
  end
end

.enqueue_at(job, timestamp) ⇒ Object

:nodoc:



27
28
29
30
31
 
# File 'lib/active_job/queue_adapters/pika_que_adapter.rb', line 27

def enqueue_at(job, timestamp) #:nodoc:
  @monitor.synchronize do
    JobWrapper.enqueue_at job.serialize, timestamp, routing_key: job.queue_name
  end
end