Method: Cloudist::Queues::BasicQueue#publish

Defined in:
lib/cloudist/queues/basic_queue.rb

#publish(payload) ⇒ Object 



106
107
108
109
110
111
 
# File 'lib/cloudist/queues/basic_queue.rb', line 106

def publish(payload)
  payload.set_reply_to(queue_name)
  body, headers = payload.to_a
  headers.merge!(:routing_key => queue.name)
  exchange.publish(body, headers)
end