A high‑performance Redis message queue for Node.js.
Simple to use. Built for scale.

Documentation · Build · Changelog

Other implementations: go-redis-smq (Go)
Language‑agnostic concepts: redis-smq-docs – architecture, queues, exchanges, and more.

✨ Why RedisSMQ?

Full‑featured – FIFO, LIFO, priority queues, pub/sub, exchanges, scheduling, consumer groups, rate limiting.
Reliable – Acknowledgements, dead‑letter queues, retries, and message persistence.
Administration included – REST API (Swagger) and Web UI for monitoring and management.
Production‑ready – Battle‑tested in high‑throughput environments.

📋 Requirements

📦 Packages

Package	Description
redis-smq	Core message queue library
redis-smq-common	Shared utilities and configuration
redis-smq-rest-api	REST API with Swagger for administration
redis-smq-web-ui	Web dashboard for queue monitoring
redis-smq-web-server	Combined web server (UI + API)
redis-smq-benchmarks	Performance testing suite

🔗 Always use matching versions across packages. See the version compatibility guide.
For cross‑implementation compatibility, refer to the language‑agnostic version matrix.

🚀 Quick Start

1. Install

# Core packages
npm install redis-smq redis-smq-common

# Pick a Redis client
npm install ioredis
# OR
npm install @redis/client

ℹ️ The @next tag pulls the latest development version from the next branch. For the stable release, use @latest (or omit the tag). Always check the version compatibility guide and the language‑agnostic compatibility matrix to ensure packages and implementations are aligned.

2. Initialize (once per process)

import { RedisSMQ } from 'redis-smq';
import { ERedisConfigClient } from 'redis-smq-common';

RedisSMQ.initialize(
  {
    client: ERedisConfigClient.IOREDIS,
    options: { host: '127.0.0.1', port: 6379 },
  },
  (err) => {
    if (err) console.error('RedisSMQ init failed:', err);
    else console.log('✅ RedisSMQ initialized');
  },
);

3. Create a Queue

import { RedisSMQ, EQueueType, EQueueDeliveryModel } from 'redis-smq';

const queueManager = RedisSMQ.createQueueManager();
queueManager.save(
  'my_queue',
  EQueueType.LIFO_QUEUE, // LIFO, FIFO, or PRIORITY
  EQueueDeliveryModel.POINT_TO_POINT, // or PUB_SUB
  (err) => {
    if (err) console.error('Queue creation failed:', err);
    else console.log('✅ Queue created');
  },
);

4. Produce a Message

import { RedisSMQ } from 'redis-smq';

const producer = RedisSMQ.createProducer();
producer.run((err) => {
  if (err) return console.error('Producer failed:', err);

  const msg = RedisSMQ.newProducibleMessage()
    .setQueue('my_queue')
    .setBody({ hello: 'world' })
    .setRetryThreshold(3); // optional

  producer.produce(msg, (err, ids) => {
    if (err) console.error('Send failed:', err);
    else console.log(`📨 Sent message(s): ${ids.join(', ')}`);
  });
});

5. Consume Messages

import { RedisSMQ } from 'redis-smq';

const consumer = RedisSMQ.createConsumer();
consumer.run((err) => {
  if (err) return console.error('Consumer failed:', err);

  const handler = (message, done) => {
    console.log('📥 Received:', message.body);
    // Process message...
    done(); // Acknowledge (or done(err) to reject)
  };

  consumer.consume('my_queue', handler, (err) => {
    if (err) console.error('Consume failed:', err);
    else console.log('👂 Listening on my_queue...');
  });
});

Using Promises (async/await)

All methods support both callbacks and Promises. Here's the same flow using async/await:

import { RedisSMQ, EQueueType, EQueueDeliveryModel } from 'redis-smq';
import { ERedisConfigClient } from 'redis-smq-common';

try {
  // Initialize
  await RedisSMQ.initialize({
    client: ERedisConfigClient.IOREDIS,
    options: { host: 'localhost', port: 6379 },
  });

  // Create queue
  const queueManager = RedisSMQ.createQueueManager();
  await queueManager.save(
    'my_queue',
    EQueueType.LIFO_QUEUE,
    EQueueDeliveryModel.POINT_TO_POINT,
  );

  // Produce message
  const producer = RedisSMQ.createProducer();
  await producer.run();
  const message = RedisSMQ.newProducibleMessage()
    .setQueue('my_queue')
    .setBody({ hello: 'world' });
  const messageIds = await producer.produce(message);
  console.log('Message published:', messageIds);

  // Consume messages
  const consumer = RedisSMQ.createConsumer();
  await consumer.run();
  await consumer.consume('my_queue', async (message) => {
    console.log('Received:', message.body);
    // Successful acknowledgement (no error thrown)
  });
} catch (err) {
  console.error('Error:', err);
}

Learn more about dual callback & promise support.

🛠️ Administration & Monitoring

The included REST API and Web UI can manage queues created by any RedisSMQ implementation (including Go).
See the respective package READMEs for setup:

📚 Documentation

📊 Benchmarks

Run the benchmark suite to measure throughput in your environment – see the benchmarks package.

🤝 Contributing

We welcome contributions! Please read CONTRIBUTING.md.

📄 License

MIT – see LICENSE.