rabbitmq_amqplib_hello_world_producer_send_message.ts

1import * as amqp from 'amqplib';
2
3async function sendMessage() {
4  try {
5    // 1. Connection to RabbitMQ server
6    const connection = await amqp.connect('amqp://localhost');
7    
8    // 2. Create a channel
9    const channel = await connection.createChannel();
10
11    const queue = 'hello';
12    const msg = 'Hello World!';
13
14    // 3. Assert a queue exists (it will be created if it doesn't)
15    await channel.assertQueue(queue, {
16      durable: false
17    });
18
19    // 4. Send a message to the queue
20    channel.sendToQueue(queue, Buffer.from(msg));
21    console.log(" [x] Sent %s", msg);
22
23    // 5. Close the connection and exit
24    await channel.close();
25    await connection.close();
26  } catch (error) {
27    console.warn(error);
28  }
29}
30
31sendMessage();