lib/sidekiq/throttled/strategy/script.rb in sidekiq-throttled-0.7.3 vs lib/sidekiq/throttled/strategy/script.rb in sidekiq-throttled-0.8.0

- old
+ new

@@ -39,11 +39,11 @@ end # Loads script to redis # @return [void] def bootstrap! - Sidekiq.redis do |conn| + namespaceless_redis do |conn| digest = conn.script(LOAD, @source) # XXX: this may happen **ONLY** if script digesting will be # changed in redis, which is not likely gonna happen. unless @digest == digest @@ -73,9 +73,22 @@ # Reads given file and returns new {Script} with its contents. # @return [Script] def self.read(file) new File.read file + end + + private + + # Yields real namespace-less redis client. + def namespaceless_redis + Sidekiq.redis do |conn| + if defined?(Redis::Namespace) && conn.is_a?(Redis::Namespace) + conn = conn.redis + end + + yield conn + end end end end end end