/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 vote197 views1 answer
Node equivalent of bash exec
Javascript Node.js
52 votes358 views6 answers
Update nodejs
Javascript Node.js
0 vote223 views2 answers
Nodejs fs directory exists
Javascript Node.js
7 votes189 views2 answers
Declare an array nodejs
Javascript Node.js
4 votes198 views2 answers
Nodejs await inside map
Javascript Node.js
0 vote196 views1 answer
Node express chat app
Javascript Node.js
18 votes202 views2 answers
Node js gitignore
Javascript Node.js
0 vote215 views1 answer
S3 list objects in folder node js
Javascript Node.js
8 votes196 views1 answer
How to split index.js to routes nodejs
Javascript Node.js
0 vote205 views1 answer
Route parameter in node
Javascript Node.js