/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 vote315 views1 answer
Nodejs array write to lines file
Javascript Node.js
0 vote297 views1 answer
Nodejs temp file
Javascript Node.js
0 vote293 views1 answer
Babel start command nodejs
Javascript Node.js
0 vote325 views2 answers
SyntaxError: Cannot use import statement outside a module node js
Javascript Node.js
2 votes297 views1 answer
Node buffer size
Javascript Node.js
0 vote258 views1 answer
How to remove an element from an array using index in javascript
Javascript Node.js
0 vote301 views1 answer
Nodejs set dns for request
Javascript Node.js
11 votes327 views2 answers
Hashing in node js
Javascript Node.js
0 vote295 views1 answer
How can I set cookie in node js using express framework?
Javascript Node.js
0 vote322 views1 answer
Monitor in production node js
Javascript Node.js