2012-01-26 15:45:04 -05:00
|
|
|
require 'celluloid'
|
2012-01-25 16:32:51 -05:00
|
|
|
|
2012-02-08 20:04:02 -05:00
|
|
|
require 'sidekiq/util'
|
|
|
|
require 'sidekiq/middleware/chain'
|
|
|
|
require 'sidekiq/middleware/server/active_record'
|
|
|
|
require 'sidekiq/middleware/server/airbrake'
|
|
|
|
require 'sidekiq/middleware/server/unique_jobs'
|
|
|
|
|
2012-01-25 16:32:51 -05:00
|
|
|
module Sidekiq
|
|
|
|
class Processor
|
2012-01-26 15:45:04 -05:00
|
|
|
include Util
|
2012-01-29 17:35:16 -05:00
|
|
|
include Celluloid
|
2012-01-25 16:32:51 -05:00
|
|
|
|
2012-02-08 20:04:02 -05:00
|
|
|
def self.middleware
|
|
|
|
@middleware ||= begin
|
|
|
|
chain = Middleware::Chain.new
|
2012-02-08 20:50:13 -05:00
|
|
|
|
|
|
|
# default middleware
|
2012-02-08 20:04:02 -05:00
|
|
|
chain.register do
|
|
|
|
use Middleware::Server::UniqueJobs, Sidekiq::Client.redis
|
|
|
|
use Middleware::Server::Airbrake
|
|
|
|
use Middleware::Server::ActiveRecord
|
|
|
|
end
|
|
|
|
chain
|
|
|
|
end
|
2012-01-25 16:32:51 -05:00
|
|
|
end
|
|
|
|
|
2012-02-08 20:04:02 -05:00
|
|
|
def initialize(boss)
|
|
|
|
@boss = boss
|
2012-02-04 19:53:09 -05:00
|
|
|
end
|
|
|
|
|
2012-02-08 20:04:02 -05:00
|
|
|
def process(msg)
|
|
|
|
klass = constantize(msg['class'])
|
|
|
|
worker = klass.new
|
|
|
|
self.class.middleware.invoke(worker, msg) do
|
|
|
|
worker.perform(*msg['args'])
|
2012-02-04 19:53:09 -05:00
|
|
|
end
|
2012-02-08 20:04:02 -05:00
|
|
|
@boss.processor_done!(current_actor)
|
2012-01-25 16:32:51 -05:00
|
|
|
end
|
2012-01-29 17:35:16 -05:00
|
|
|
|
|
|
|
# See http://github.com/tarcieri/celluloid/issues/22
|
|
|
|
def inspect
|
|
|
|
"Sidekiq::Processor<#{object_id}>"
|
|
|
|
end
|
2012-01-25 16:32:51 -05:00
|
|
|
end
|
|
|
|
end
|