module RabbitWQ::Queues

Protected Instance Methods

channel() click to toggle source
# File lib/rabbit_wq/queues.rb, line 12
def channel
  @channel ||= mq.create_channel.tap do |c|
    c.prefetch( config.prefetch )
  end
end
mq() click to toggle source
# File lib/rabbit_wq/queues.rb, line 6
def mq
  @mq ||= ::Bunny.new.tap do |bunny|
    bunny.start
  end
end