Proper SIGINT handling from ruby rpc_server

titanoboa · Jul 7, 2011 · b0a44e3 · b0a44e3
1 parent e4b167c
commit b0a44e3
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/ruby/rpc_server.rb b/ruby/rpc_server.rb
@@ -12,6 +12,12 @@ def fib(n)
   channel = AMQP::Channel.new(connection)
   queue   = channel.queue("rpc_queue")
 
+  Signal.trap("INT") do
+    connection.close do
+      EM.stop { exit }
+    end
+  end
+
   channel.prefetch(1)
 
   queue.subscribe(:ack => true) do |header, body|