/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 vote177 views1 answer
Node js check if a user exists in mysql
Javascript Node.js
4 votes188 views1 answer
Node express post request json
Javascript Node.js
10 votes180 views5 answers
What is dotenv in nodejs
Javascript Node.js
0 vote175 views1 answer
Objectid is not defined node js mongodb
Javascript Node.js
0 vote182 views1 answer
Orm for postgres node js
Javascript Node.js
0 vote265 views1 answer
Most popular company with nodejs
Javascript Node.js
0 vote185 views1 answer
Custom error nodejs
Javascript Node.js
9 votes209 views4 answers
Simple nodejs server
Javascript Node.js
7 votes173 views3 answers
Generate random number nodejs
Javascript Node.js
0 vote161 views1 answer
Token authenticate nodejs
Javascript Node.js