From ec9bd438e4a782b2deda932f2f14c13aef9a6ccd Mon Sep 17 00:00:00 2001
From: "Bo-Chun Louis Chen(VM)" <louistw@uab.edu>
Date: Sat, 22 Feb 2020 06:38:10 +0000
Subject: [PATCH] Add delete_queue method
---
rc_rmq.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/rc_rmq.py b/rc_rmq.py
index 14f969c..8d43102 100644
--- a/rc_rmq.py
+++ b/rc_rmq.py
@@ -54,6 +54,9 @@ class RCRMQ(object):
self._channel.close()
self._connection.close()
+ def delete_queue(self):
+ self._channel.queue_delete(self.QUEUE)
+
def publish_msg(self, obj):
if 'routing_key' in obj:
self.ROUTING_KEY = obj['routing_key']
--
GitLab