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