/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

0 vote240 views1 answer
Set 404 handling via express in node
Javascript Node.js
0 vote264 views1 answer
Common library for .net and node js for encryption
Javascript Node.js
2 votes251 views1 answer
Node js createHash
Javascript Node.js
0 vote277 views1 answer
Create path if not exist node js
Javascript Node.js
2 votes248 views1 answer
Promise method in node js
Javascript Node.js
1 vote282 views2 answers
Read and update csv file in nodejs
Javascript Node.js
4 votes254 views2 answers
Define a while loop in node js
Javascript Node.js
0 vote275 views1 answer
Nodejs catch uncaught exception
Javascript Node.js
6 votes248 views1 answer
Add numbers from array nodejs
Javascript Node.js
0 vote263 views1 answer
How to load and parse the json data in node js
Javascript Node.js