Class: Sidekiq::Batch::Middleware::ServerMiddleware
- Inherits:
-
Object
- Object
- Sidekiq::Batch::Middleware::ServerMiddleware
- Defined in:
- lib/sidekiq/batch/middleware.rb
Instance Method Summary collapse
Instance Method Details
#call(_worker, msg, _queue) ⇒ Object
14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/sidekiq/batch/middleware.rb', line 14 def call(_worker, msg, _queue) if (bid = msg['bid']) begin Thread.current[:bid] = bid yield Thread.current[:bid] = nil Batch.process_successful_job(bid) rescue Batch.process_failed_job(bid, msg['jid']) raise ensure Thread.current[:bid] = nil end else yield end end |