Skip to content
Snippets Groups Projects
Commit ca69cda7 authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Add delete_queue method

parent b7cb6aab
No related branches found
No related tags found
2 merge requests!23Feat resolve uid gid,!9Feat connection module
...@@ -54,6 +54,9 @@ class RCRMQ(object): ...@@ -54,6 +54,9 @@ class RCRMQ(object):
self._channel.close() self._channel.close()
self._connection.close() self._connection.close()
def delete_queue(self):
self._channel.queue_delete(self.QUEUE)
def publish_msg(self, obj): def publish_msg(self, obj):
if 'routing_key' in obj: if 'routing_key' in obj:
self.ROUTING_KEY = obj['routing_key'] self.ROUTING_KEY = obj['routing_key']
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment