amqp queue_delete 以异步方式捕获错误

Question

我刚刚开始将 pika(v 0.9.4) 与 Tornado 一起使用（通过使用 pika.adapters.tornado_connection.TornadoConnection），我想知道使用时捕获错误的适当方法是什么，当您尝试删除的队列不存在时，请说：queue_delete。 RabbitMQ 引发 AMQPError，但我不确定如何以异步方式处理它。

有人对此有任何见解吗？

Answer 1

免责声明：我是 Stormed-amqp 的作者

，我建议尝试使用 stormed-amqp

import logging
logging.basicConfig()

from tornado.ioloop import IOLoop
from stormed import Connection

def on_connect():
    ch = conn.channel()
    ch.queue_declare(queue='hello', durable=False)
    ch.queue_declare(queue='hello', durable=True)

def on_error(e):
    print "Got Connection error", e.reply_text, e.reply_code
    io_loop.stop()

conn = Connection(host='localhost')
conn.on_error = on_error
conn.connect(on_connect)
io_loop = IOLoop.instance()
io_loop.start()

Answer 2

尽量避免错误。如果您声明与队列的连接，但该连接不存在，则会创建该连接。然后立即删除。

或者，如果您将在下周左右再次使用该队列，即它不是一次性使用，则只需将其保留并作为系统管理活动处理删除，以清理长期空闲队列。

或者只需使用自动删除属性声明您的队列，当您断开连接时它们就会消失。