Contents

# -*- coding: utf-8 -*-

require 'isono'
require 'eventmachine'

Signal.trap('EXIT') { EventMachine.stop }

def restart_reactor_and_messaging_client
  if EventMachine.reactor_running?
    EventMachine.stop
    Dcmgr.class_eval {
      @messaging_client = nil
    }
  end
  Thread.new { EventMachine.epoll; EventMachine.run; }
end

restart_reactor_and_messaging_client

Dcmgr.class_eval {
  def self.messaging
    @messaging_client ||= Isono::MessagingClient.start(conf.amqp_server_uri) do
      node_name 'dcmgr'
      node_instance_id "#{Isono::Util.default_gw_ipaddr}:#{Process.pid}"
    end
  end
}

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
wakame-vdc-agents-11.12.0	config/initializers/isono.rb
wakame-vdc-dcmgr-11.12.0	config/initializers/isono.rb
wakame-vdc-agents-11.06.0	config/initializers/isono.rb
wakame-vdc-dcmgr-11.06.0	config/initializers/isono.rb