module Fleck

# File lib/fleck.rb, line 22
def self.configure
  yield @config if block_given?
  @config
end

# File lib/fleck.rb, line 37
def self.connection(options = {})
  opts = Fleck.config.default_options.merge(options)
  key  = "ampq://#{opts[:user]}@#{opts[:host]}:#{opts[:port]}#{opts[:vhost]}"
  conn = @connections[key]
  if !conn || conn.closed?
    opts[:logger] = Fleck.logger.clone
    opts[:logger].progname += "::Bunny"
    logger.info "New connection #{key}"
    conn = Bunny.new(opts)
    conn.start
    @connections[key] = conn
  end
  return conn
end

# File lib/fleck.rb, line 27
def self.logger
  @config.logger
end

# File lib/fleck.rb, line 31
def self.register_consumer(consumer_class)
  unless @consumers.include?(consumer_class)
    @consumers << consumer_class
  end
end

# File lib/fleck.rb, line 52
def self.terminate
  @connections.each do |key, connection|
    begin
      Fleck.logger.info "Closing connection #{key}"
      connection.close
    rescue => e
      Fleck.logger.error e.inspect
    end
  end
  @connections.clear

  true
end