frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2025-03-01 10:37:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bugfix: ack & better docs regardign ack

Browse Source
This commit is contained in:
Olivier Verhaegen 2023-04-17 14:45:43 +02:00 committed by GitHub
parent 564944ebca
commit 71737046fd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
io/stomp/18-stomp.js
View File

@ -334,6 +334,12 @@ module.exports = function(RED) {
} }
} }
/**
* Acknowledge (a) message(s) that was received from the specified queue.
* @param {String} queue The queue/topic to send an acknowledgement for
* @param {String} messageId ID of the message that was received from the server, which can be found in the reponse header as `message-id`
* @param {String} transaction Optional transaction name
*/
node.ack = function(queue, messageId, transaction = undefined) { node.ack = function(queue, messageId, transaction = undefined) {
if (node.connected) { if (node.connected) {
node.client.ack(messageId, node.subscriptionIds[queue], transaction); node.client.ack(messageId, node.subscriptionIds[queue], transaction);
@ -452,7 +458,7 @@ module.exports = function(RED) {
setStatusDisconnected(node); setStatusDisconnected(node);
node.on("input", function(msg, send, done) { node.on("input", function(msg, send, done) {
node.serverConnection.ack(msg.messageId, node.topic, msg.transaction); node.serverConnection.ack(node.topic, msg.messageId, msg.transaction);
done(); done();
}); });