module Resque::ThreadSafeRedis

def self.resque_override
  self.thread_resque_override ||= ResqueOverride.new
end

def redis
  Resque::ThreadSafeRedis.resque_override.data_store_override || super
end

def with_per_thread_redis_override(redis_instance, &block)
  Resque::ThreadSafeRedis.resque_override.enable_with(redis_instance, &block)
end