/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 vote277 views1 answer
Node serialport isopen
Javascript Node.js
1 vote300 views1 answer
Try catch in node js
Javascript Node.js
0 vote282 views1 answer
Creating room in ws node js
Javascript Node.js
0 vote330 views1 answer
Node js file dowload progress bar
Javascript Node.js
0 vote292 views1 answer
How to change function name while exporting in node
Javascript Node.js
1 vote290 views1 answer
Use static pages nodejs
Javascript Node.js
0 vote301 views1 answer
How to get datetime in nodejs
Javascript Node.js
7 votes281 views1 answer
Path.basename nodejs
Javascript Node.js
8 votes314 views2 answers
Settimeout node js
Javascript Node.js
0 vote281 views1 answer
How to check record successfully delete in mongodb node js
Javascript Node.js