node-red-contrib-queuemanager 0.2.4

Node-RED implements queue manager.

npm install node-red-contrib-queuemanager

Node-Red nodes for queue managed of nodes .

Queue Manager (Configuration)

Queue Manager

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.

Queue Manager Node


Queue Manager Admin

Queue Manager

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.

Queue Manager Admin Node

Node input processes messages where the topic drives process

Topic List

out message payload contains of metrics for all queues

Topic pause

Queue all incoming messages. Out message payload contains OK

release

Activate queue processing if paused. Out message payload contains OK

Topic set

Change controlling parameters for queue manager. Payload contains JSON object with properties that can be set. Out message payload contains OK


Queue

Queue

A queuing node which sets how many active messages can be active, maximum queue depth and a time out for the message.

Queue Node


Checkpoint

Checkpoint

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.


Rollback

Rollback

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.


Adding Commit/Rollback to Function

commit-rollback


Install

Run the following command in the root directory of your Node-RED install

npm install node-red-contrib-queuemanager

Test

Test/example flow in test/testflow.json which requires loadbalance

Test


Version

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


Author

Peter Prib

Collection Info

prev

Node Info

Version: 0.2.4
Updated 4 years, 1 month ago
License: GPL-3.0
Rating: not yet rated

Actions

Rate:

Downloads

5 in the last week

Nodes

  • Queue
  • Queue Manager
  • Queue Manager Admin
  • Queue Checkpoint
  • Queue Rollback

Keywords

  • node-red
  • queuemanager
  • rollback
  • queue
  • checkpoint

Maintainers