examples/hello_world.rb in amqp-0.8.0.rc13 vs examples/hello_world.rb in amqp-0.8.0.rc14

@@ -17,12 +17,10 @@
   exchange = channel.direct("")
 
   queue.subscribe do |payload|
     puts "Received a message: #{payload}. Disconnecting..."
 
-    connection.close {
-      EM.stop { exit }
-    }
+    connection.close { EventMachine.stop }
   end
 
   exchange.publish "Hello, world!", :routing_key => queue.name, :app_id => "Hello world"
 end