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