swift-mq

swift-mq is a lightweight in-memory message queue system for Node.js. It provides basic queue functionalities including message prioritization, delayed processing, retries, and scheduling, designed to be simple and easy to integrate into your applications.

Features

Priority Queue: Supports priority levels for messages. Higher priority messages are processed before lower priority ones.

Delayed Messages: Allows scheduling messages to be processed after a specified delay. This is useful for deferred tasks or scheduling tasks at a future time.

Retries: Configurable number of retries for processing messages in case of failures. Useful for handling transient errors during processing.

Scheduled Jobs: Supports scheduling messages to be processed at specific times. This allows for advanced scheduling of tasks.

Batch Processing: Enqueue and process multiple messages in batches, improving efficiency when dealing with large volumes of messages.

Queue State Logging: Logs the state of the queue, including the number of messages and their details. This can be helpful for debugging and monitoring.

Installation

npm install swift-mq

Usage

const express = require('express');
const { SimpleInMemoryQueue } = require('swift-mq'); // Adjust path if necessary

const app = express();
const queue = new SimpleInMemoryQueue();

app.use(express.json());

// Enqueue a message
app.post('/enqueue', (req, res) => {
  const { task, payload, priority, delay, retries, scheduledAt } = req.body;
  queue.enqueue({ task, payload, priority, delay, retries, scheduledAt });
  res.status(200).send('Message enqueued');
});

// Dequeue and process a message
app.get('/process', (req, res) => {
  const message = queue.dequeue();
  if (message) {
    console.log('Processing message:', message);
    res.status(200).send('Message processed');
  } else {
    res.status(200).send('No messages in the queue');
  }
});

// Start the server
const PORT = 3000;
app.listen(PORT, () => {
  console.log(`Server is running on port ${PORT}`);
});