queenmq_redis_task_queue_push_and_process_quickstart.ts

1import { QueenMQ, Task } from 'queen-mq';
2
3// Configuration for the Redis connection
4const connection = {
5  host: 'localhost',
6  port: 6379,
7};
8
9// Initialize QueenMQ
10const queen = new QueenMQ({ connection });
11
12// Define a queue and its processing logic
13const myQueue = queen.queue('email-notifications', async (task: Task) => {
14  console.log('Processing task:', task.id);
15  console.log('Task data:', task.data);
16  
17  // Simulate task processing
18  await new Promise((resolve) => setTimeout(resolve, 1000));
19  
20  return { status: 'sent' };
21});
22
23// Example: Pushing a task to the queue
24async function runQuickstart() {
25  const task = await myQueue.push({
26    to: 'user@example.com',
27    subject: 'Welcome to QueenMQ',
28    body: 'This is a test message.',
29  });
30
31  console.log(`Task ${task.id} has been queued.`);
32}
33
34runQuickstart().catch(console.error);