module Watership

# File lib/watership.rb, line 42
def self.close(name)
  if name == :all
    registered.each do |(name, client)|
      client.close
    end
  else
    registered.fetch(name).close
  end
end

# File lib/watership.rb, line 60
def self.enqueue(name, opts)
  registered.fetch(name.to_sym).enqueue(opts)
end

# File lib/watership.rb, line 56
def self.logger
  @logger ||= defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end

# File lib/watership.rb, line 52
def self.logger=(logger)
  @logger = logger
end

# File lib/watership.rb, line 32
def self.reconnect(name)
  if name == :all
    registered.each do |(name, client)|
      client.reconnect
    end
  else
    registered.fetch(name).reconnect
  end
end

# File lib/watership.rb, line 24
def self.register(name, uri, env = 'production')
  registered[name.to_sym] = Client.new(uri, env)
end

# File lib/watership.rb, line 28
def self.registered
  @registered_instances ||= {}
end