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