def delete_exchange(self, name):
"""Delete exchange by name
:param name: name of exchange
:type name: str
"""
with self.connections[self.connection].acquire() as conn:
exchange = self.exchanges.pop(name, Exchange(name, channel=conn))
exchange.delete()
self.logger.debug('Exchange "%s" was deleted', name)
评论列表
文章目录