Class: Trinidad::Extensions::ThreadedResque::Worker

Inherits:
Resque::Worker
  • Object
show all
Defined in:
lib/trinidad_threaded_resque_extension/worker.rb

Instance Method Summary collapse

Constructor Details

#initialize(*queues) ⇒ Worker

Returns a new instance of Worker.



7
8
9
10
 
# File 'lib/trinidad_threaded_resque_extension/worker.rb', line 7

def initialize(*queues)
  super(*queues)
  @cant_fork = true
end

Instance Method Details

#register_signal_handlers ⇒ Object

we can’t let resque trap signal



13
14
 
# File 'lib/trinidad_threaded_resque_extension/worker.rb', line 13

def register_signal_handlers
end

#to_s ⇒ Object

override to_s and separate different workers by there thread id



17
18
19
 
# File 'lib/trinidad_threaded_resque_extension/worker.rb', line 17

def to_s
  @to_s ||= "#{hostname}:#{Process.pid}-#{Thread.current.object_id}:#{@queues.join(',')}"
end