any-queue

0.1.0 • Public • Published

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);

Package Sidebar

Install

npm i any-queue

Weekly Downloads

0

Version

0.1.0

License

MIT

Unpacked Size

45.3 kB

Total Files

16

Last publish

Collaborators

  • gmunguia