Method: Resque::DataStore::Workers#register_worker

Defined in:
lib/resque/data_store.rb

#register_worker(worker) ⇒ Object 



241
242
243
244
245
246
 
# File 'lib/resque/data_store.rb', line 241

def register_worker(worker)
  @redis.pipelined do |piped|
    piped.sadd(:workers, [worker.id])
    worker_started(worker, redis: piped)
  end
end