Class: WorkerRoulette::QueueLatency::Foreman

Inherits:
Object
  • Object
show all
Defined in:
lib/worker_roulette/queue_latency.rb

Instance Method Summary collapse

Instance Method Details

#process(work_order, _channel) ⇒ Object 



6
7
8
9
10
 
# File 'lib/worker_roulette/queue_latency.rb', line 6

def process(work_order, _channel)
  work_order['headers'].merge!(
    "queued_at" => (Time.now.to_f * GRANULARITY).to_i) if work_order.is_a?(Hash) && work_order["headers"]
  work_order
end