Method: Peatio::MQ::Client.connect!

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

.connect! ⇒ Object 



8
9
10
11
12
13
14
15
16
17
 
# File 'lib/peatio/mq/client.rb', line 8

def connect!
  options = {
    host:     ENV["RABBITMQ_HOST"] || "0.0.0.0",
    port:     ENV["RABBITMQ_PORT"] || "5672",
    username: ENV["RABBITMQ_USER"],
    password: ENV["RABBITMQ_PASSWORD"],
  }
  @connection = Bunny.new(options)
  @connection.start
end