examples/mq/logger.rb in amqp-0.5.3 vs examples/mq/logger.rb in amqp-0.5.5

@@ -96,10 +96,10 @@
     log.debug 'login', :session => 'abc', :user => 123
 
     log = Logger.new(:webserver, :timestamp, :hostname, &log.printer)
     log.info 'Request for /', :GET, :session => 'abc'
 
-    AMQP.stop
+    AMQP.stop{ EM.stop_event_loop }
 
   end
 }
 
 __END__