sql-mq-worker v1.0.3

SQL Message Queue Worker

Treat your SQL table as a message queue that can be worked on by worker processes. This software was inspired by Resque for Redis, but I wanted to have a similar lightweight system for use with small, simple SQL-based node.js applications.

Make sure to use SQL transactions when working jobs and updating the state of of the database record object.

Dependencies

Node.js
Sequelize - SQL Object-Relational Mapper for node.js
Postgres, Mysql, or SQLite database

Installation

npm install sql-mq-worker

USAGE

Every SQL-MQ Worker object performs a job or function, ultimately calling a callback function and proceeding with polling to get the next database record.

function job(dbRecordInstance, callback){
  // POST to a service endpoint, for example.

  request.post(SERVICE_URL, dbRecordInstance).complete(callback);
}

A SQL-MQ worker must also be provided with a Sequelize Class object, which is queried using the predicate option:

worker = new SqlMqWorker({
  Class: Payment, 
  predicate: { where: { state: "toSend" }},
  job: sendPaymentToServceJob
})

worker.start();