Sha256: 2eafeb6670555aa7c31b5ef0d0a40776ce4155ec478c44866c2071a851e2405f
Contents?: true
Size: 255 Bytes
Versions: 11
Compression:
Stored size: 255 Bytes
Contents
module RabbitWQ
module Queues
protected
def mq
@mq ||= ::Bunny.new.tap do |bunny|
bunny.start
end
end
def channel
@channel ||= mq.create_channel.tap do |c|
c.prefetch( 10 )
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems