Class: ActiveJob::QueueAdapters::PikaQueRails5

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

Defined Under Namespace

Classes: JobWrapper

Instance Method Summary collapse

Constructor Details

#initialize ⇒ PikaQueRails5

Returns a new instance of PikaQueRails5.



41
42
43
 
# File 'lib/active_job/queue_adapters/pika_que_adapter.rb', line 41

def initialize
  @monitor = Monitor.new
end

Instance Method Details

#enqueue(job) ⇒ Object

:nodoc:



45
46
47
48
49
 
# File 'lib/active_job/queue_adapters/pika_que_adapter.rb', line 45

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

#enqueue_at(job, timestamp) ⇒ Object

:nodoc:



51
52
53
54
55
 
# File 'lib/active_job/queue_adapters/pika_que_adapter.rb', line 51

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