/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 vote341 views1 answer
Http module nodejs
Javascript Node.js
0 vote371 views1 answer
Node load testing-check
Javascript Node.js
8 votes345 views2 answers
Node js error
Javascript Node.js
0 vote368 views1 answer
Stdout nodejs
Javascript Node.js
0 vote365 views2 answers
MongooseError: Operation `users.insertOne()` buffering timed out after 10000ms node js
Javascript Node.js
0 vote350 views1 answer
Version control api nodejs best practices
Javascript Node.js
14 votes334 views1 answer
Get if there is a value in an array node js
Javascript Node.js
0 vote329 views1 answer
API version control v1 v2 in NodeJs (loosely coupled)
Javascript Node.js
0 vote346 views1 answer
Nohup run nodejs
Javascript Node.js
1 vote372 views1 answer
Nodejs require everything without prefix
Javascript Node.js