我正在升级到 pika 1.1.0,并进行了一些健全性测试。我有:
- 在下面放了一个断点
- 断开网络
- 跨过这个命令
...并且没有抛出异常。这是预期的吗?
channel.basic_publish(
exchange=EXCHANGE,
routing_key=ROUTING_KEY,
body=message,
properties=pika.BasicProperties(
delivery_mode=MQ_TRANSIENT_DELIVERY_MODE,
headers=headers,
)
)
连接是通过以下方式创建的:
connection = pika.BlockingConnection(pika.ConnectionParameters(
host=rabbit_config.host,
credentials=credentials,
port=rabbit_config.port,
connection_attempts=1,
blocked_connection_timeout=10,
retry_delay=5,
socket_timeout=20,
heartbeat=30, ))
更新:如果我channel.confirm_delivery()
在此之前打电话,我成功地得到了 AMQPError。
但是,这不会在 60 秒内发生(这不是我的 ConnectionParameters)。我怎样才能让它更快地注意到连接丢失?