Module: Sidekiq::TestingClient

Included in:
Client
Defined in:
lib/sidekiq/testing.rb

Instance Method Summary collapse

Instance Method Details

#atomic_push(conn, payloads) ⇒ Object 



67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/sidekiq/testing.rb', line 67

def atomic_push(conn, payloads)
  if Sidekiq::Testing.fake?
    payloads.each do |job|
      job = Sidekiq.load_json(Sidekiq.dump_json(job))
      job["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 = Object.const_get(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