diff --git a/rc_rmq.py b/rc_rmq.py index 14f969c69643dd64600acb3a24a31eccdc079c09..8d43102e19bea1701b62a064510ea0dd16723912 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']