/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 vote227 views1 answer
Nodejs get appdata path
Javascript Node.js
0 vote260 views1 answer
How to split a string into chunks nodejs
Javascript Node.js
0 vote263 views1 answer
Node js login and registration
Javascript Node.js
3 votes229 views3 answers
Node get current url
Javascript Node.js
11 votes248 views4 answers
Get file extension nodejs
Javascript Node.js
0 vote232 views1 answer
Reached heap limit Allocation failed - JavaScript heap out of memory nodejs
Javascript Node.js
0 vote246 views1 answer
Hot to set file views in nodejs
Javascript Node.js
2 votes242 views1 answer
Node js mongodb update nested object
Javascript Node.js
0 vote269 views1 answer
How to debug node js file in webpack
Javascript Node.js
0 vote236 views1 answer
Node save wav base64
Javascript Node.js