Method: Wildcloud::Router::Core#initialize

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

#initialize ⇒ Core

Returns a new instance of Core.



26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/wildcloud/router/core.rb', line 26

def initialize
  @counter = {}
  @routes = {}

  Router.logger.info('Core') { "Starting" }
  connect_amqp

  Router.logger.info('Core') { "Requesting synchronization" }
  publish({ :node => Router.configuration["node"]["name"], :type => :sync })

  @queue.subscribe do |metadata, message|
    handle(metadata, message)
  end
end