/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 vote193 views3 answers
Aes 256 file encryption node js
Javascript Node.js
0 vote197 views2 answers
Delete dir nodejs
Javascript Node.js
0 vote181 views2 answers
Width and height with node js
Javascript Node.js
0 vote211 views1 answer
Morgan nodejs github
Javascript Node.js
-1 vote200 views1 answer
Mysql node js github
Javascript Node.js
0 vote186 views1 answer
Isodate mongodb nodejs
Javascript Node.js
7 votes196 views3 answers
Input in node js
Javascript Node.js
1 vote139 views2 answers
How to find the last index of an array in javascript
Javascript Node.js
0 vote238 views1 answer
Nodejs kill hidden process
Javascript Node.js
-1 vote190 views1 answer
Node package.json type module
Javascript Node.js