module Sidekiq::TestingClient

Public Instance Methods

raw_push(payloads) click to toggle source
Calls superclass method
# File lib/sidekiq/testing.rb, line 75
def raw_push(payloads)
  if Sidekiq::Testing.fake?
    payloads.each do |job|
      job = Sidekiq.load_json(Sidekiq.dump_json(job))
      job.merge!('enqueued_at' => Time.now.to_f) unless job['at']
      Queues.push(job['queue'], job['class'], job)
    end
    true
  elsif Sidekiq::Testing.inline?
    payloads.each do |job|
      klass = Sidekiq::Testing.constantize(job['class'])
      job['id'] ||= SecureRandom.hex(12)
      job_hash = Sidekiq.load_json(Sidekiq.dump_json(job))
      klass.process_job(job_hash)
    end
    true
  else
    super
  end
end