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