Sha256: 02b7186e3ae2db77482ce4e1bcac49358b87891bce025192ea7fc236f29bdc22
Contents?: true
Size: 264 Bytes
Versions: 4
Compression:
Stored size: 264 Bytes
Contents
require "amqp/ext/em" module AMQP # @deprecated # @api public 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
4 entries across 4 versions & 1 rubygems
Version | Path |
---|---|
amqp-0.8.0.rc2 | lib/amqp/deprecated/fork.rb |
amqp-0.8.0.rc1 | lib/amqp/deprecated/fork.rb |
amqp-0.8.0.pre.beta1 | lib/amqp/deprecated/fork.rb |
amqp-0.8.0.beta1 | lib/amqp/deprecated/fork.rb |