lib/amqp.rb in tmm1-amqp-0.6.0 vs lib/amqp.rb in tmm1-amqp-0.6.1

@@ -97,6 +97,16 @@
         @conn = nil
         @closing = false
       }
     end
   end
+
+  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