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.
28
29
30
31
|
# File 'lib/sidekiq/processor.rb', line 28
def initialize(boss)
@boss = boss
redis {|x| x.sadd('workers', self) }
end
|
Class Method Details
.default_middleware ⇒ Object
.middleware ⇒ Object
15
16
17
|
# File 'lib/sidekiq/processor.rb', line 15
def self.middleware
raise "Sidekiq::Processor.middleware is now Sidekiq.server_middleware"
end
|
Instance Method Details
#inspect ⇒ Object
45
46
47
|
# File 'lib/sidekiq/processor.rb', line 45
def inspect
"#<Processor #{to_s}>"
end
|
#process(msg, queue) ⇒ Object
33
34
35
36
37
38
39
40
41
42
|
# File 'lib/sidekiq/processor.rb', line 33
def process(msg, queue)
klass = constantize(msg['class'])
worker = klass.new
stats(worker, msg, queue) do
Sidekiq.server_middleware.invoke(worker, msg, queue) do
worker.perform(*msg['args'])
end
end
@boss.processor_done!(current_actor)
end
|
#to_s ⇒ Object
49
50
51
|
# File 'lib/sidekiq/processor.rb', line 49
def to_s
@str ||= "#{hostname}:#{process_id}-#{Thread.current.object_id}:default"
end
|