Method: Cloudist::Queues::BasicQueue#initialize

Defined in:
lib/cloudist/queues/basic_queue.rb

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

Returns a new instance of BasicQueue.



14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/cloudist/queues/basic_queue.rb', line 14

def initialize(queue_name, options = {})
  @prefetch ||= options.delete(:prefetch) || 1

  options = {
    :auto_delete => true,
    :durable => false,
    :nowait => true
  }.update(options)

  @queue_name, @options = queue_name, options

  setup
end