diff --git a/rc_rmq.py b/rc_rmq.py
index 8a005de245c5be68fc721e6f0ecfc327d7e890a2..30f7c18871d09c8c4db5c5ba41edc6b70e49afcc 100644
--- a/rc_rmq.py
+++ b/rc_rmq.py
@@ -76,7 +76,10 @@ class RCRMQ(object):
         self.connect()
 
         self._consumer_tag = self._channel.basic_consume(self.QUEUE,obj['cb'])
-        self._channel.start_consuming()
+        try:
+            self._channel.start_consuming()
+        except KeyboardInterrupt:
+            self._channel.stop_consuming()
 
         self.disconnect()