Node-Red nodes for queue managed of nodes .
Management node which can turn other nodes to act like queue, checkpoint or rollback by wrapping base node input with queue manager input which is called before passing message to input of node. For example catch node can be made to act like rollback node.
Management node which can turn other nodes to act like queue, checkpoint or rollback by wrappering base node input with queue manager input which is called before passing mEssage to input of node. For example catch node can be made to act like rollback node.
Node input processes messages where the topic drives process
out message payload contains of metrics for all queues
Queue all incoming messages. Out message payload contains OK
release
Activate queue processing if paused. Out message payload contains OK
Change controlling parameters for queue manager. Payload contains JSON object with properties that can be set. Out message payload contains OK
A queuing node which sets how many active messages can be active, maximum queue depth and a time out for the message.
A point that applies any commits in commit stack of message and activates next waiting message. Any node can add to commit stack by:
msg.processStack.add({node:node
,commit:function(processStack) {
// add logic to commit process
processStack.next();
}
});
The functions are called with scope of node property in FILO order.
A point that applies any rollbacks in rollback stack of message and activates next waiting message. Any node can add to rollback stack by:
msg.processStack.push({node:node,
rollback:function(processStack) {
// add logic to rollback process
processStack.next();
}
})
The functions are called with scope of node property in FILO order.
Run the following command in the root directory of your Node-RED install
npm install node-red-contrib-queuemanager
Test/example flow in test/testflow.json which requires loadbalance
0.2.5 nodes-started to flow-started
0.2.4 bug fixes: hold and maximum action per qm. action calls on queue
0.2.3 Add hold queue on rollback to QM, queue and rollback.
0.2.2 Add a few more queue controls (+/- active). Get better details if fail. Fix bug with maximum allowed. Display messages and add security around these calls.
0.2.1 fix to work with node-red v1 which changed from emitters to callback
0.1.2 Fix queue consumption to FIFO
0.1.0 Major rewrite to have stack processor be callback thus allow async rollback/commit calls
0.0.4 Add ability to hold/release queue and release a single message
0.0.3 Add queue status to queue node and empty queue function
0.0.2 Fix time issue with queue manager being recognised and control on overflow message flooding
0.0.1 Base