class Queight::ConnectionCache
Public Class Methods
new()
click to toggle source
# File lib/queight/connection_cache.rb, line 5 def initialize @cache ||= {} end
Public Instance Methods
call(options)
click to toggle source
# File lib/queight/connection_cache.rb, line 13 def call(options) @cache[options] ||= ChannelPool.new(options) end
reset_cache!()
click to toggle source
# File lib/queight/connection_cache.rb, line 9 def reset_cache! @cache.values.each(&:reset_cache!) end