kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Use Celluloid's thread pool for #perform to get a full thread stack, fixes #115

Browse source
This commit is contained in:
Mike Perham 2012-04-06 11:26:16 -07:00
parent a587be0bd7
commit e832145833
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lib/sidekiq/processor.rb
View file

@ -30,9 +30,11 @@ module Sidekiq
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'])
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)