/usr/lib/ruby/vendor_ruby/amqp/deprecated/fork.rb is in ruby-amqp 0.9.5-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | # encoding: utf-8
require "amqp/ext/em"
module AMQP
# @deprecated
# @private
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
end
|