# 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