Method: Sidekiq::Manager#processor_result

Defined in:
lib/sidekiq/manager.rb

#processor_result(processor, reason = nil) ⇒ Object 



69
70
71
72
73
74
75
76
77
78
 
# File 'lib/sidekiq/manager.rb', line 69

def processor_result(processor, reason = nil)
  @plock.synchronize do
    @workers.delete(processor)
    unless @done
      p = Processor.new(@config, &method(:processor_result))
      @workers << p
      p.start
    end
  end
end