Class: Cloudist::JobQueue

Inherits:
Queues::BasicQueue show all
Defined in:
lib/cloudist/queues/job_queue.rb

Instance Attribute Summary

Attributes inherited from Queues::BasicQueue

#channel, #exchange, #options, #prefetch, #queue, #queue_name

Instance Method Summary collapse

Methods inherited from Queues::BasicQueue

#destroy, #inspect, #log, #print_status, #publish, #publish_to_q, #setup, #setup_exchange, #subscribe, #tag, #teardown

Constructor Details

#initialize(queue_name, options = {}) ⇒ JobQueue

Returns a new instance of JobQueue.



4
5
6
7
8
9
10
11
 
# File 'lib/cloudist/queues/job_queue.rb', line 4

def initialize(queue_name, options={})
  options[:auto_delete] = false
  options[:nowait] = false

  @prefetch = Cloudist.worker_prefetch
  puts "Prefetch: #{@prefetch}"
  super(queue_name, options)
end