class PikaQ::Queues::Base

Public Class Methods

create(channel, options = { durable: false, auto_delete: false, exclusive: false }) click to toggle source
# File lib/pika_q/queues/base.rb, line 6
def self.create(channel, options = { durable: false, auto_delete: false, exclusive: false })
  new(channel, generated_queue_name, options)
end
generated_queue_name() click to toggle source
# File lib/pika_q/queues/base.rb, line 10
def self.generated_queue_name
  "#{self.to_s.gsub('::','.')}.#{ENV['RUBY_ENV']}".downcase
end