mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Doc update, bump version
This commit is contained in:
parent
f2c70bfa39
commit
017ba262ce
3 changed files with 15 additions and 1 deletions
|
@ -1,3 +1,8 @@
|
|||
2.0.2
|
||||
-----------
|
||||
|
||||
- Fix "Retry Now" button on individual retry page. (ezkl)
|
||||
|
||||
2.0.1
|
||||
-----------
|
||||
|
||||
|
|
|
@ -8,6 +8,10 @@ require 'sidekiq/middleware/server/logging'
|
|||
require 'sidekiq/middleware/server/timeout'
|
||||
|
||||
module Sidekiq
|
||||
##
|
||||
# The Processor receives a message from the Manager and actually
|
||||
# processes it. It instantiates the worker, runs the middleware
|
||||
# chain and then calls Sidekiq::Worker#perform.
|
||||
class Processor
|
||||
include Util
|
||||
include Celluloid
|
||||
|
@ -29,6 +33,11 @@ module Sidekiq
|
|||
def process(msg, queue)
|
||||
klass = constantize(msg['class'])
|
||||
worker = klass.new
|
||||
|
||||
# Celluloid actor calls are performed within a Fiber.
|
||||
# This would give us a terribly small 4KB stack on MRI
|
||||
# so we use Celluloid's defer to run things in a thread pool
|
||||
# in order to get a full-sized stack for the Worker.
|
||||
defer do
|
||||
stats(worker, msg, queue) do
|
||||
Sidekiq.server_middleware.invoke(worker, msg, queue) do
|
||||
|
|
|
@ -1,3 +1,3 @@
|
|||
module Sidekiq
|
||||
VERSION = "2.0.1"
|
||||
VERSION = "2.0.2"
|
||||
end
|
||||
|
|
Loading…
Reference in a new issue