Sha256: 57d06425785c6792b4285de1d8ca20b0c7242e31ee635de7665a789af886a26c
Contents?: true
Size: 595 Bytes
Versions: 8
Compression:
Stored size: 595 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
#def work_exchange
#@work_exchange ||= channel.direct( RabbitWQ.configuration.work_exchange, durable: true )
#end
#def work_queue
#@work_queue ||= channel.queue( RabbitWQ.configuration.work_queue,
#durable: true ).
#bind( work_exchange )
#end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems