兔子 - 通道和连接未关闭

Question

我正在使用以下Nodejs脚本在我的RabbitMQ队列中发布消息：

const amqp = require("amqplib");
[...]

const publishMsgToQueue = async (job, res) => {
  const queue = job.queueName;
  const msg = { url: job.msg };

  try {
    const connection = await amqp.connect(Rabbitmq.host);
    const channel = await connection.createChannel();
    await channel.assertQueue(queue, { durable: true });
    await channel.sendToQueue(queue, Buffer.from(JSON.stringify(msg)));

    await channel.close();
    await connection.close();

  } catch (error) {
    logger.error(
      "[AMQP] Error publishing to RabbitMQ",
      job.msg,
      "queue name:",
      job.queueName
    );
  }
};

此功能在循环中以为单位来发布消息数组。

当所有消息发布时，我都有许多连接和频道打开...虽然应该通过Channel.Class.Close和Connection.close.Close ...但不是...

我在其他帖子上进行了很多检查，但是我没有成功……

我在哪里错了？