Method: Peatio::MQ::Client#publish

Defined in:
lib/peatio/mq/client.rb

#publish(ex_name, type, id, event, payload) ⇒ Object 



34
35
36
37
38
39
 
# File 'lib/peatio/mq/client.rb', line 34

def publish(ex_name, type, id, event, payload)
  routing_key = [type, id, event].join(".")
  serialized_data = JSON.dump(payload)
  exchange(ex_name).publish(serialized_data, routing_key: routing_key)
  Peatio::Logger.debug { "published event to #{routing_key} " }
end