0

我正在升级到 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)。我怎样才能让它更快地注意到连接丢失?

4

0 回答 0