Module: Debci::AMQP
- Defined in:
- lib/debci/amqp.rb
Class Method Summary collapse
Class Method Details
.amqp_channel ⇒ Object
20 21 22 23 24 25 |
# File 'lib/debci/amqp.rb', line 20 def self.amqp_channel @conn ||= Bunny.new(Debci.config.amqp_server).tap do |conn| conn.start end @channel ||= @conn.create_channel end |
.get_queue(arch) ⇒ Object
5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
# File 'lib/debci/amqp.rb', line 5 def self.get_queue(arch) @queues ||= {} @queues[arch] ||= begin opts = { durable: true, arguments: { 'x-max-priority': 10, } } q = ENV['debci_amqp_queue'] || "debci-tests-#{arch}-#{Debci.config.backend}" self.amqp_channel.queue(q, opts) end end |