queueball v0.1.0

Queueball

A simple RabbitMQ-based work queue

Example

const { Consumer, Producer } = require('@casestack/queueball');

const config = {
  rabbitmqUrl: 'amqp://guest:guest@localhost:5672',
  name: 'example',
};

async function example() {
  const producer = new Producer(config);
  const consumer = new Consumer(config);

  await Promise.all([producer.start(), consumer.start()]);

  consumer.processJob = job => console.log(job.payload.exampleKey);
  producer.enqueue({ exampleKey: 'example' });
}

example();