@gautham-rao-niveus/queue-system v1.0.0

Pub Sub Implementation using bull

Installing the package:

npm i @<name-space>/pubsub

Example Queues created:

http://localhost:3000/mail_queue

http://localhost:3000/test_queue

Usage

Initialising listner for subscription event

Initialise the listner by invoking subscribeTask function from mail task obeject with Handler as arrgumnet

const Task = require("@<name-space>/pubsub");
const mailTask = new Task("mail_queue");
mailTask.subscribeTask(handler);

Adding a task to queue

Task can be added to queue by calling addTask function from publisher/publisher.js file with Queue name and Task Data to be processed

const Task = require("@<name-space>/pubsub");
const mailTask = new Task("mail_queue");
mailTask.addTask({ payload: {} });

Example Usage

Example usage can be found in publisher/index.js for publishTask function and subscriber/index.js for onSubscription listner event.