Method: QueueingProxy::DSL#run

Defined in:
lib/queueing_proxy/dsl.rb

#run ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/queueing_proxy/dsl.rb', line 54

def run
  unless EM.reactor_running?
    EM.run{ run }
  else
    # Setup multiple backends
    backends.each {|b|
      b.logger @logger
      b.workers.each(&:run)
    }
    frontends.each do |host, port|
      Frontend.new(@logger, host, port, backends).run
    end
  end
end