/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

1 vote197 views1 answer
How to delete the last part of a string in node js
Javascript Node.js
0 vote175 views2 answers
How to install chalk in node js
Javascript Node.js
12 votes169 views4 answers
Nodejs base64
Javascript Node.js
0 vote179 views1 answer
How to use a fixed time zone in nodejs
Javascript Node.js
9 votes168 views2 answers
Nodejs dirname
Javascript Node.js
0 vote214 views1 answer
Node js file dowload progress bar
Javascript Node.js
0 vote117 views1 answer
Node express mongo boilerplate with jwt
Javascript Node.js
10 votes180 views2 answers
Moment string to date convert node js
Javascript Node.js
0 vote181 views1 answer
Node js exit with error code
Javascript Node.js
0 vote177 views1 answer
Access to XMLHttpRequest has been blocked by CORS policy node js
Javascript Node.js