Module: Funktor::FakeJobQueue

Defined in:
lib/funktor/fake_job_queue.rb

Class Method Summary collapse

Class Method Details

.clear_all ⇒ Object 



14
15
16
 
# File 'lib/funktor/fake_job_queue.rb', line 14

def self.clear_all
  jobs.clear
end

.jobs ⇒ Object 



10
11
12
 
# File 'lib/funktor/fake_job_queue.rb', line 10

def self.jobs
  @jobs ||= Hash.new { |hash, key| hash[key] = [] }
end

.push(payload) ⇒ Object 



5
6
7
8
 
# File 'lib/funktor/fake_job_queue.rb', line 5

def self.push(payload)
  payload = payload.with_indifferent_access
  jobs[payload["worker"].to_s].push(payload)
end