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!
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