Redis Nest Client

redis-nest-client.ts

import Redis from "ioredis";

// Create pub and sub clients
const sub = new Redis();
const pub = new Redis();

// Set the queue names
const queue = "getHello";
const replyQueue = `${queue}.reply`;

// Subscribe to the queue
sub.subscribe(queue);

// Listen for messages
sub.on("message", async (channel, rawMessage) => {
  if (channel !== queue) return;
  // Parse the message
  const message = JSON.parse(rawMessage) as IncomingMessage;

  // Do something with the message and reply
  for (let index = 0; index < 3; index++) {
    const firstResponse: OutgoingMessage = {
      id: message.id,
      // Dispose if the message is the last one
      isDisposed: index === 2,
      response: `Hello ${message.data} - ${index}`,
    };

    // Publish the response
    pub.publish(replyQueue, JSON.stringify(firstResponse));
  }
});

interface IncomingMessage {
  pattern: string;
  data: string;
  id: string;
}

interface OutgoingMessage {
  response: string;
  isDisposed: boolean;
  id: string;
}