class Shoryuken::Batch::Middleware::ClientMiddleware
Public Instance Methods
call(sqs_msg) { || ... }
click to toggle source
# File lib/shoryuken/batch/middleware.rb, line 7 def call(sqs_msg) if (batch = Thread.current[:bid]) msg = JSON.parse(sqs_msg[:message_body]) batch.increment_job_queue(msg['job_id']) if (msg[:bid] = batch.bid) sqs_msg[:message_body] = msg.to_json end yield end