Displaying 1 result from an estimated 1 matches for "kill_reactor".
2010 Nov 09
2
AMQP and Unicorn (mq gem)
...or/plugins/qusion/lib/amqp.rb
module AMQP
def self.start_web_dispatcher(amqp_settings={})
@settings = settings.merge(amqp_settings)
case Qusion::ServerSpy.server_type
when :passenger
PhusionPassenger.on_event(:starting_worker_process) do |forked|
if forked
EM.kill_reactor
Thread.current[:mq], @conn = nil, nil
end
Thread.new { start }
die_gracefully_on_signal
end
when :standard
Thread.new { start }
die_gracefully_on_signal
when :evented
die_gracefully_on_signal
when :none # << HERE
Thr...