Class: Sidekiq::Processor
- Inherits:
-
Object
- Object
- Sidekiq::Processor
show all
- Includes:
- Celluloid, Util
- Defined in:
- lib/sidekiq/processor.rb
Class Method Summary
collapse
Instance Method Summary
collapse
Methods included from Util
#constantize, logger, #logger, logger=, #process_id, #redis, #watchdog
Constructor Details
#initialize(boss) ⇒ Processor
Returns a new instance of Processor.
23
24
25
26
|
# File 'lib/sidekiq/processor.rb', line 23
def initialize(boss)
@boss = boss
redis {|x| x.sadd('workers', self) }
end
|
Class Method Details
.default_middleware ⇒ Object
Instance Method Details
#inspect ⇒ Object
42
43
44
|
# File 'lib/sidekiq/processor.rb', line 42
def inspect
"#<Processor #{to_s}>"
end
|
#process(msg, queue) ⇒ Object
28
29
30
31
32
33
34
35
36
37
38
39
|
# File 'lib/sidekiq/processor.rb', line 28
def process(msg, queue)
klass = constantize(msg['class'])
worker = klass.new
defer do
stats(worker, msg, queue) do
Sidekiq.server_middleware.invoke(worker, msg, queue) do
worker.perform(*msg['args'])
end
end
end
@boss.processor_done!(current_actor)
end
|
#to_s ⇒ Object
46
47
48
|
# File 'lib/sidekiq/processor.rb', line 46
def to_s
@str ||= "#{hostname}:#{process_id}-#{Thread.current.object_id}:default"
end
|