Sha256: eb62bef22cc424aed93d0b53151023ba22fb0f9fabbd3b71e744a13e0189e52e

Contents?: true

Size: 260 Bytes

Versions: 11

Compression:

Stored size: 260 Bytes

Contents

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

11 entries across 11 versions & 1 rubygems

Version Path
amqp-0.8.0.rc13 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc12 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc11 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc10 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc9 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc8 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc7 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc6 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc5 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc4 lib/amqp/deprecated/fork.rb
amqp-0.8.0.rc3 lib/amqp/deprecated/fork.rb