@@ -22,7 +22,7 @@ spec = Gem::Specification.new do |s| ] s.authors = ["Aman Gupta"] - s.add_dependency('eventmachine') + s.add_dependency('eventmachine', '>= 0.12.4') # ruby -rpp -e' pp `git ls-files`.split("\n") ' s.files = [ amqp.gemspec @@ -5,47 +5,4 @@ rescue LoadError require 'eventmachine' end -#:stopdoc: - -if EM::VERSION < '0.12.2' - - def EventMachine::run blk=nil, tail=nil, &block - @tails ||= [] - tail and @tails.unshift(tail) - - if reactor_running? - (b = blk || block) and b.call # next_tick(b) - else - @conns = {} - @acceptors = {} - @timers = {} - begin - @reactor_running = true - initialize_event_machine - (b = blk || block) and add_timer(0, b) - run_machine - ensure - release_machine - @reactor_running = false - end - - until @tails.empty? - @tails.pop.call - end - end - end - - def EventMachine::fork_reactor &block - Kernel.fork do - if self.reactor_running? - self.stop_event_loop - self.release_machine - self.instance_variable_set( '@reactor_running', false ) - end - self.run block - end - end - -end - -require 'ext/emfork' \ No newline at end of file +require 'ext/emfork' lib/ext/em.rb f371c726635af8bb21cdb9819c59aa17d3fc1d3a Aman Gupta aman@tmm1.net http://github.com/tmm1/amqp/commit/abef873a778dc73ae9dc410199eb3422e5f8029f abef873a778dc73ae9dc410199eb3422e5f8029f 2009-10-27T14:57:53-07:00 2009-10-27T14:57:53-07:00 Oops, wrong fix for 0.12.10 incompat. ab0156ceb567c626f8baea7ccfc6f9fb10d72de6 Aman Gupta aman@tmm1.net