Method: Peatio::MQ::Client#subscribe

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

#subscribe(ex_name, &callback) ⇒ Object 



41
42
43
44
45
46
47
48
49
 
# File 'lib/peatio/mq/client.rb', line 41

def subscribe(ex_name, &callback)
  suffix = "#{Socket.gethostname.split(/-/).last}#{Random.rand(10_000)}"
  queue_name = "ranger.#{suffix}"

  @channel
    .queue(queue_name, durable: false, auto_delete: true)
    .bind(exchange(ex_name), routing_key: "#").subscribe(&callback)
  Peatio::Logger.info "Subscribed to exchange #{ex_name}"
end