/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

8 votes131 views1 answer
Path.dirname nodejs
Javascript Node.js
0 vote129 views1 answer
Bcrypt always return faslse in node js
Javascript Node.js
18 votes134 views4 answers
Nodejs create folder if not exist
Javascript Node.js
1 vote122 views1 answer
Get lines as list from file node js
Javascript Node.js
0 vote126 views1 answer
Write head node js
Javascript Node.js
0 vote129 views1 answer
Node sudo nvm
Javascript Node.js
0 vote120 views2 answers
Node js check ram usage
Javascript Node.js
0 vote123 views1 answer
How to get user info from google oauth node js
Javascript Node.js
0 vote137 views1 answer
Manage nodejs versions on windows
Javascript Node.js
57 votes241 views6 answers
Node js throw error
Javascript Node.js