Module: Resque::ThreadSafeRedis

Defined in:
lib/resque/thread_safe_redis.rb

Overview

Set and access Resque.redis in a thread-safe way.

Defined Under Namespace

Classes: ResqueOverride

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.resque_override ⇒ Object 



5
6
7
 
# File 'lib/resque/thread_safe_redis.rb', line 5

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

Instance Method Details

#redis ⇒ Object Also known as: data_store 



9
10
11
 
# File 'lib/resque/thread_safe_redis.rb', line 9

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

#with_per_thread_redis_override(redis_instance, &block) ⇒ Object 



14
15
16
 
# File 'lib/resque/thread_safe_redis.rb', line 14

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