class ActiveJob::Locking::Adapters::SuoRedis

Public Instance Methods

create_lock_manager() click to toggle source
# File lib/activejob/locking/adapters/suo-redis.rb, line 7
def create_lock_manager
  mapped_options = {connection: {host: self.options.hosts.first},
                    stale_lock_expiration: self.options.lock_time,
                    acquisition_timeout: self.options.lock_acquire_time}

  Suo::Client::Redis.new(self.key, mapped_options)
end
lock() click to toggle source
# File lib/activejob/locking/adapters/suo-redis.rb, line 15
def lock
  self.lock_token = self.lock_manager.lock
end
unlock() click to toggle source
# File lib/activejob/locking/adapters/suo-redis.rb, line 19
def unlock
  self.lock_manager.unlock(self.lock_token)
end