class Sidekiq::Paquet::Middleware

Public Instance Methods

call(worker, item, queue, redis_pool = nil) { || ... } click to toggle source
# File lib/sidekiq/paquet/middleware.rb, line 4
def call(worker, item, queue, redis_pool = nil)
  return yield if defined?(Sidekiq::Testing)

  retrying = item.key?('failed_at'.freeze)

  if item['bundled'.freeze] && !retrying
    Bundle.append(item)
    false
  else
    yield
  end
end