/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

13 votes213 views4 answers
Writefile in node js
Javascript Node.js
38 votes203 views6 answers
Nodejs cors
Javascript Node.js
2 votes195 views1 answer
Node js createHash
Javascript Node.js
57 votes256 views6 answers
Node js throw error
Javascript Node.js
1 vote200 views1 answer
New node js project vs code
Javascript Node.js
0 vote206 views1 answer
Node js request download file
Javascript Node.js
0 vote244 views1 answer
Node js download image from url as buffer
Javascript Node.js
2 votes212 views2 answers
Nodejs csv to json from link
Javascript Node.js
1 vote209 views1 answer
Nodejs mysql connection pool
Javascript Node.js
2 votes211 views1 answer
Settimeout nodejs await
Javascript Node.js