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