queen_mq_redis_producer_consumer_quickstart.ts

1import { Producer, Consumer, Connection } from 'queen-mq';
2
3async function main() {
4  // 1. Establish a connection to Redis
5  const connection = new Connection({
6    host: '127.0.0.1',
7    port: 6379,
8  });
9
10  const queueName = 'email_queue';
11
12  // 2. Initialize a Producer and send a message
13  const producer = new Producer(queueName, connection);
14  await producer.pull({
15    to: 'user@example.com',
16    subject: 'Welcome!',
17    body: 'Hello from Queen-MQ',
18  });
19  console.log('Message sent to the queue.');
20
21  // 3. Initialize a Consumer to process messages
22  const consumer = new Consumer(queueName, connection);
23  consumer.execute(async (job) => {
24    console.log('Processing job:', job.data);
25    // Return true to acknowledge success
26    return true;
27  });
28
29  console.log('Consumer is listening...');
30}
31
32main().catch(console.error);