lib/sidekiq/limit_fetch/redis.rb in sidekiq-limit_fetch-2.0 vs lib/sidekiq/limit_fetch/redis.rb in sidekiq-limit_fetch-2.0.1

@@ -1,13 +1,27 @@
 module Sidekiq::LimitFetch::Redis
+  extend self
+
   # prevent blocking of fetcher
   # more bullet-proof and faster (O_O)
   # than using Celluloid::IO
-  def redis
-    Sidekiq.redis do |redis|
+  def nonblocking_redis
+    redis do |redis|
       begin
         Celluloid::Future.new { yield redis }.value
       end
     end
   rescue Celluloid::Task::TerminatedError
+  end
+
+  def redis
+    Sidekiq.redis {|it| yield it }
+  end
+
+  def determine_namespace
+    redis do |it|
+      if it.respond_to?(:namespace) and it.namespace
+        it.namespace + ':'
+      end
+    end
   end
 end