/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 vote303 views1 answer
How to install node js in plesk
Javascript Node.js
0 vote306 views2 answers
Nodejs fs directory exists
Javascript Node.js
0 vote329 views1 answer
Nodejs catch uncaught exception
Javascript Node.js
0 vote349 views1 answer
How to check if a folder exists in node js
Javascript Node.js
0 vote305 views1 answer
Readfle nodejs
Javascript Node.js
-1 vote324 views2 answers
Nodejs bodyparser form data
Javascript Node.js
0 vote294 views2 answers
Redis pub or sub nodejs
Javascript Node.js
0 vote286 views1 answer
Remove port number from url node js
Javascript Node.js
0 vote318 views1 answer
React native typescript nodejs timeout
Javascript Node.js
0 vote304 views1 answer
Node base64 to audio
Javascript Node.js