lib/amqp/deprecated/fork.rb in amqp-0.8.0.rc2 vs lib/amqp/deprecated/fork.rb in amqp-0.8.0.rc3

- old
+ new

@@ -1,15 +1,15 @@ require "amqp/ext/em" module AMQP # @deprecated - # @api public + # @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 \ No newline at end of file + end +end