我想部署一个RoR应用程序,它执行一些异步任务。我使用workling,消息队列是RabbitMQ。这个组合与Starling完美无瑕地工作,但我们决定更改MQ for Rabbit。 我读的地方,我应该包括下面的代码在我的environment.rbPhusion Passenger + Workling + RabbitMQ
require 'mq'
if defined?(PhusionPassenger)
PhusionPassenger.on_event(:starting_worker_process) do |forked|
if forked
if EM.reactor_running?
EM.stop_event_loop
EM.release_machine
EM.instance_variable_set('@reactor_running', false)
end
Thread.current[:mq] = nil
AMQP.instance_variable_set('@conn', nil)
end
th = Thread.current
Thread.new{
AMQP.connect(:host => 'localhost'){
th.wakeup
}
}
Thread.stop
end
end
但是,现在的Apache与消息完全失败:服务器遇到一个内部错误或配置错误,无法完成您的请求