From 21bf79c3e635ee87b332b948c5554e8748c75c50 Mon Sep 17 00:00:00 2001
From: "Bo-Chun Louis Chen(VM)" <louistw@uab.edu>
Date: Sat, 22 Feb 2020 05:01:22 +0000
Subject: [PATCH] Add exception handle in start_consume method
---
rc_rmq.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/rc_rmq.py b/rc_rmq.py
index 8a005de..30f7c18 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()
--
GitLab