/Javascript/Node.js/Node close rabbitmq connection

Node close rabbitmq connection

  async sendMsg(msg) {
    const channel = await this.initChannel();

    const sendResult = channel.sendToQueue(this.queue, Buffer.from(msg), {
      persistent: true,
    });

    if (!sendResult) {
      await new Promise((resolve) => channel.once('drain', () => resolve));
    }
  }

  async close() {
    if (this.channel) await this.channel.close();
    await this.conn.close();
  }

Source: stackoverflow.com

Similar codes

112 votes233 views6 answers
Node js install ubuntu
Javascript Node.js
1 vote189 views1 answer
Read from s3 bucket nodejs
Javascript Node.js
0 vote192 views1 answer
How to prevent xss attacks in node js
Javascript Node.js
20 votes188 views4 answers
Node list files in directory
Javascript Node.js
0 vote196 views1 answer
Open folder node js
Javascript Node.js
5 votes172 views3 answers
Node js get url from request
Javascript Node.js
0 vote184 views1 answer
Image downloader extension in nodejs
Javascript Node.js
0 vote196 views1 answer
Node js performance is not defined
Javascript Node.js
31 votes193 views5 answers
Update node js version ubuntu
Javascript Node.js
26 votes188 views6 answers
Nodejs open file
Javascript Node.js