/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

6 votes351 views3 answers
Get random number node js
Javascript Node.js
0 vote333 views1 answer
Node js post method
Javascript Node.js
0 vote317 views1 answer
Front end display data frmo database nodejs html
Javascript Node.js
21 votes371 views1 answer
Node if path exists
Javascript Node.js
0 vote325 views1 answer
Reached heap limit Allocation failed - JavaScript heap out of memory nodejs
Javascript Node.js
0 vote357 views1 answer
Node convert string to hash
Javascript Node.js
1 vote347 views1 answer
Data not write in file node js
Javascript Node.js
2 votes359 views1 answer
Node readFileSync json
Javascript Node.js
5 votes369 views2 answers
Node js version 14
Javascript Node.js
0 vote323 views1 answer
Sendgrid api calss in node js
Javascript Node.js