Test - Redis FIFO writer to Postgres

Redis FIFO writer to Postgres

import redis from "redis";

client = redis.createClient();
exitProcessor = false;

queueNext = () => {
      process.nextTick(() => {
          // Messages are pushed with RPUSH, making this a FIFO queue
        client.blpop('queue', 1, queueFn);
      
      })
};

queueFn = function(err, msg) {
      if (!err && msg && msg.length === 2) { // Message is always array with two values
        console.log(msg);
      }
      setTimeout(queueNext,10);  // pause for 200ms
    };
 
//Start Processor
queueNext();
  
// Add messages
for(var i=1; i<100; i++) {
  client.rpush("queue", "Message " + i);
 }