any-queue

a-queue

WIP

import { Queue, Worker } from "any-queue";
import anyQueueMysql from "any-queue-mysql";
 
const persistenceInterface = anyQueueMysql({
  uri: "mysql://root:nt3yx7ao2e9@localhost/any-queue-demo"
});
 
const queue = Queue({ persistenceInterface, name: "foo" });
const worker = Worker({
  persistenceInterface,
  queueName: "foo",
  instructions: job => {
    console.log(job);
  }
});
 
worker.punchIn();
 
queue.now({ "bar": "foobar" });
// Will eventually print "[Object object]".
 
setTimeout(() => worker.punchOut(), 100);