Module: Debci::AMQP
- Defined in:
- lib/debci/amqp.rb
Class Method Summary collapse
- .amqp_channel ⇒ Object
- .amqp_options ⇒ Object
- .get_queue(arch, backend = Debci.config.backend) ⇒ Object
- .results_queue ⇒ Object
Class Method Details
.amqp_channel ⇒ Object
27 28 29 30 31 32 |
# File 'lib/debci/amqp.rb', line 27 def self.amqp_channel @conn ||= Bunny.new(Debci.config.amqp_server, ).tap do |conn| conn.start end @channel ||= @conn.create_channel end |
.amqp_options ⇒ Object
34 35 36 37 38 39 40 41 42 |
# File 'lib/debci/amqp.rb', line 34 def self. { tls: Debci.config.amqp_ssl, tls_cert: Debci.config.amqp_cert, tls_ca_certificates: Debci.config.amqp_cacert, tls_key: Debci.config.amqp_key, verify_peer: true, } end |
.get_queue(arch, backend = Debci.config.backend) ⇒ Object
7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
# File 'lib/debci/amqp.rb', line 7 def self.get_queue(arch, backend = Debci.config.backend) @queues ||= {} @queues[arch] ||= begin opts = { durable: true, arguments: { 'x-max-priority': 10, } } q = ENV['debci_amqp_queue'] || "debci-tests-#{arch}-#{backend}" self.amqp_channel.queue(q, opts) end end |