MyMq

gistfile1.rb

class MyMq
  def self.client
    unless @client
      c = Bunny.new(APP_CONFIG["cloudamqp_url"], :logging => true)
      c.start
      @client = c
    end
    @client
  end
  
  def self.stop
    @client.stop if @client
  end
  
  def self.purge
    messages_queue.purge
  end

  def self.nameless_exchange
    @nameless_exchange ||= client.exchange('')
  end

  def self.messages_queue
    @messages_queue ||= client.queue("#{Rails.env}:messages")
  end

end