Bugfix: ack

This commit is contained in:
Olivier Verhaegen 2023-04-17 14:20:23 +02:00 committed by GitHub
parent d14b0711c6
commit 564944ebca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -336,9 +336,9 @@ module.exports = function(RED) {
node.ack = function(queue, messageId, transaction = undefined) {
if (node.connected) {
node.client.ack(messageId, subscriptionIds[queue], transaction);
node.client.ack(messageId, node.subscriptionIds[queue], transaction);
} else {
node.error("Can't publish, not connected");
node.error("Can't send acknowledgement, not connected");
}
}