/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 votes174 views1 answer
Refresh after delete in node
Javascript Node.js
57 votes329 views6 answers
Node js throw error
Javascript Node.js
1 vote201 views1 answer
Postgresql nodejs
Javascript Node.js
1 vote206 views1 answer
Random id number nodejs
Javascript Node.js
1 vote203 views1 answer
Node js ffmpeg image to video
Javascript Node.js
0 vote180 views1 answer
Insert multiple Row in SQL database with NodeJS
Javascript Node.js
0 vote174 views1 answer
How to prevent xss attacks in node js
Javascript Node.js
13 votes219 views6 answers
How to create node js server
Javascript Node.js
17 votes179 views3 answers
Read json file node js
Javascript Node.js
0 vote176 views1 answer
Typescript in nodejs
Javascript Node.js