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