RabbitMQ/AMQP Helper - SendToQueue Typescript

amqp-helper.ts

import amqp, { Channel, Connection } from 'amqplib';

export class AMQPHelper {
    private connection?: Connection;
    private channel?: Channel;

    constructor(private readonly url: string)
    {}

    public async sendToQueue (queueName: string, data: string) {
        if (!this.connection) {
            await this.connect();
        }

        await this.channel?.assertQueue(queueName);
        await this.channel?.sendToQueue(queueName, Buffer.from(data))
    }

    private async connect() {
        this.connection = await amqp.connect(this.url);
        this.channel = await this.connection.createChannel();
    }
}

Usage :

const helper = new AMQPHelper('amqp://login:password@localhost:5672');
await rabbitMQ.sendToQueue(
                    'someQueueName',
                    JSON.stringify({ foo: 'bar' })
                )

Hi do you have a helper function that listens in on a queue 🙂I've tried the following but it never seems to listen

public async receive() {
var queue = "pingQueue";

    this.channel?.assertQueue(queue, {
        durable: false,
    });

    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);

    this.channel?.consume(
        queue,
        function (msg) {
            console.log(" [x] Received %s", msg?.content.toString());
        },
        {
            noAck: true,
        },
    );
}