/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

36 votes201 views5 answers
Access-control-allow-origin nodejs express
Javascript Node.js
8 votes205 views3 answers
Error handling in node js
Javascript Node.js
0 vote221 views1 answer
How to make pages from list in nodejs
Javascript Node.js
0 vote247 views1 answer
Get string before specific character nodejs
Javascript Node.js
14 votes166 views1 answer
Node console colors
Javascript Node.js
0 vote235 views3 answers
Node js create pdf from html
Javascript Node.js
-3 votes250 views3 answers
Node qrcode
Javascript Node.js
0 vote206 views1 answer
Node command get to much time
Javascript Node.js
0 vote229 views1 answer
Transaction commit rollback nodejs
Javascript Node.js
2 votes223 views3 answers
Port already in use node js
Javascript Node.js