Method: Wildcloud::Router::Core#connect_amqp

Defined in:
lib/wildcloud/router/core.rb

#connect_amqp ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/wildcloud/router/core.rb', line 41

def connect_amqp
  Router.logger.info('Core') { "Connecting to broker" }
  @amqp = AMQP.connect(Router.configuration["amqp"])
  Router.logger_add_amqp(@amqp)
  @channel = AMQP::Channel.new(@amqp)
  # Communication infrastructure
  @topic = @channel.topic('wildcloud.router')
  @queue = @channel.queue("wildcloud.router.#{Router.configuration["node"]["name"]}")
  @queue.bind(@topic, :routing_key => "nodes")
  @queue.bind(@topic, :routing_key => "node.#{Router.configuration["node"]["name"]}")
end