# File lib/amqp/deprecated/fork.rb, line 8 def self.fork(workers) EM.fork(workers) do # clean up globals in the fork Thread.current[:mq] = nil AMQP.instance_variable_set('@conn', nil) yield end end