如何重新发送未确认的主动 MQ 消息？

Question

我正在处理一个套接字 IO 应用程序，该应用程序使用来自 ActiveMQ 队列的消息。我正在为节点JS使用踩踏库

在大多数情况下，它工作正常，但我需要能够重新发送未确认的消息。跳过 amq.ack（消息）的消息不会被重新尝试并显示为正在等待 ActiveMQ Web 控制台。有没有办法让我重新发送它们？

const subscribeHeaders = {
    destination,
    ack: 'client-individual'
};

amq.subscribe(subscribeHeaders, (error, message) => {
    if (error) {
        logger.error(`subscribe error ${error.message}`);
        return;
    }

    message.readString('utf-8', (err, body) => {
        if (err) {
            logger.error(`read message error ${err.message}`);
            return;
        }
        const notificationData = JSON.parse(body);

        const { deviceId } = notificationData;

        if (io.sockets.adapter.rooms[deviceId]) {
            io.to(deviceId).emit('notification', notificationData);
            amq.ack(message);
        }
    });
});

Answer 1

如果您不确认消息，它们将保持挂起状态，直到您确认它们或关闭它们所锁定的使用者(或连接)为止。在你的情况下，你也许可以通过取消订阅来获得释放，并让那些消息重新发送给另一个消费者。