Module: WhoCan

Defined in:

lib/who_can.rb,
lib/who_can/base.rb,
lib/who_can/pinger.rb,
lib/who_can/logging.rb,
lib/who_can/version.rb,
lib/who_can/responder.rb,
lib/who_can/heartbeater.rb,
lib/who_can/heartbeater/ekg.rb,
lib/who_can/heartbeater/beat.rb,
lib/who_can/connection_manager.rb,
lib/who_can/connection_wrapper.rb

Defined Under Namespace

Modules: Heartbeater, Logging Classes: Base, ChannelPoolError, ConnectionManager, ConnectionWrapper, DelayMustBeSetError, Pinger, PoolIsNotOpenException, Responder, TimeoutError, WhoCanError

Constant Summary

DEFAULT_PING_EXCHANGE =

'who_can.default.fanout'

DEFAULT_CONNECT_URL =

'amqp://127.0.0.1'

VERSION =

"0.3.5"

Class Method Summary

• .connect_url ⇒ Object
• .connect_url=(config) ⇒ Object
• .logger ⇒ Object
• .logger=(log) ⇒ Object
• .new(*a, &b) ⇒ Object

Class Method Details

.connect_url ⇒ Object

# File 'lib/who_can.rb', line 23

def self.connect_url
  @config ||= DEFAULT_CONNECT_URL
end

.connect_url=(config) ⇒ Object

# File 'lib/who_can.rb', line 27

def self.connect_url=(config)
  @config = config
end

.logger ⇒ Object

# File 'lib/who_can.rb', line 35

def self.logger
  @logger ||= Logger.new('/dev/null').tap { |l| l.level = Logger::FATAL }
end

.logger=(log) ⇒ Object

# File 'lib/who_can.rb', line 39

def self.logger=(log)
  @logger = log
end

.new(*a, &b) ⇒ Object

# File 'lib/who_can.rb', line 31

def self.new(*a, &b)
  WhoCan::Base.new(*a, &b)
end