/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

2 votes121 views1 answer
Node print stdin
Javascript Node.js
0 vote114 views1 answer
Node js list all installed modules
Javascript Node.js
-1 vote121 views4 answers
Python to node js converter
Javascript Node.js
0 vote115 views1 answer
Node path relative
Javascript Node.js
1 vote124 views4 answers
Cors error in node js express
Javascript Node.js
2 votes138 views2 answers
Node js delete folder with files
Javascript Node.js
0 vote116 views1 answer
Nodejs api to logged in users count on an application
Javascript Node.js
0 vote124 views1 answer
Node process.env.PORT
Javascript Node.js
0 vote106 views1 answer
Redirect to 404 page in node js express
Javascript Node.js
1 vote129 views1 answer
Sanitizer content nodejs
Javascript Node.js