Sha256: 318d93cc5780b05c21e192f34bde6f707f62471b624b05c316ab5c41841a8b2d
Contents?: true
Size: 279 Bytes
Versions: 21
Compression:
Stored size: 279 Bytes
Contents
# 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
Version data entries
21 entries across 21 versions & 1 rubygems