module Watership

Constants

CLEAR_CHANNEL_EXCEPTIONS
CLEAR_CONNECTION_EXCEPTIONS
CONNECTION_EXCEPTIONS
VERSION

Public Class Methods

close(name) click to toggle source
# 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
enqueue(name, opts) click to toggle source
# File lib/watership.rb, line 60
def self.enqueue(name, opts)
  registered.fetch(name.to_sym).enqueue(opts)
end
Also aliased as: enqueue!
enqueue!(name, opts)
Alias for: enqueue
logger() click to toggle source
# File lib/watership.rb, line 56
def self.logger
  @logger ||= defined?(Rails) ? Rails.logger : Logger.new(STDOUT)
end
logger=(logger) click to toggle source
# File lib/watership.rb, line 52
def self.logger=(logger)
  @logger = logger
end
reconnect(name) click to toggle source
# 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
register(name, uri, env = 'production') click to toggle source
# File lib/watership.rb, line 24
def self.register(name, uri, env = 'production')
  registered[name.to_sym] = Client.new(uri, env)
end
registered() click to toggle source
# File lib/watership.rb, line 28
def self.registered
  @registered_instances ||= {}
end