Class: Funktor::JobPusher

Inherits:
Object
  • Object
show all
Includes:
TestingPusher
Defined in:
lib/funktor/job_pusher.rb

Instance Method Summary collapse

Instance Method Details

#push(payload) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
 
# File 'lib/funktor/job_pusher.rb', line 6

def push(payload)
  job_id = SecureRandom.uuid
  payload[:job_id] = job_id

  Funktor.job_pusher_middleware.invoke(payload) do
    client.send_message({
      queue_url: queue_url(payload),
      message_body: Funktor.dump_json(payload)
    })
    return job_id
  end
end