Method: Cloudist::Queues::BasicQueue#setup

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

#setup ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/cloudist/queues/basic_queue.rb', line 32

def setup
  return if @setup.eql?(true)

  @channel ||= AMQP::Channel.new(Cloudist.connection) do
    channel.prefetch(self.prefetch, false) if self.prefetch
  end

  @queue = @channel.queue(queue_name, options)

  setup_exchange

  @setup = true
end