/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

0 vote99 views1 answer
Node sass how to configure number of spaces
Javascript Node.js
2 votes102 views1 answer
Nodejs log all objects
Javascript Node.js
1 vote107 views1 answer
Nodejs import instead of require
Javascript Node.js
23 votes113 views6 answers
Create node js server
Javascript Node.js
0 vote119 views1 answer
Node js download file to folder
Javascript Node.js
2 votes100 views1 answer
What is morgan in nodejs
Javascript Node.js
0 vote115 views1 answer
Node Locking
Javascript Node.js
0 vote111 views1 answer
Node js install wbm
Javascript Node.js
18 votes98 views2 answers
Node gitignore
Javascript Node.js
1 vote127 views1 answer
Node js ffmpeg image to video
Javascript Node.js