/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 vote98 views2 answers
Convert base64 to image nodejs
Javascript Node.js
0 vote101 views1 answer
Nodejs css cotent tipe
Javascript Node.js
13 votes97 views3 answers
Node sleep
Javascript Node.js
0 vote92 views1 answer
Node js function infinite parameters
Javascript Node.js
1 vote115 views2 answers
Res.write in node js
Javascript Node.js
0 vote51 views1 answer
Nodejs connection to localhost refused mysql errno -61
Javascript Node.js
2 votes108 views1 answer
Node console showing object object
Javascript Node.js
1 vote101 views2 answers
Copy directory in nodejs
Javascript Node.js
91 votes206 views4 answers
How to install node js 14 on ubuntu
Javascript Node.js
0 vote108 views1 answer
Nodejs version api
Javascript Node.js