/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

1 vote358 views1 answer
Node js response header
Javascript Node.js
6 votes372 views3 answers
Nodejs btoa
Javascript Node.js
0 vote342 views2 answers
Search with multiple field in node js mongodb
Javascript Node.js
0 vote340 views1 answer
Node cron install
Javascript Node.js
0 vote453 views1 answer
Windows terminal vai kill all node js port
Javascript Node.js
0 vote331 views1 answer
Isodate mongodb nodejs
Javascript Node.js
0 vote333 views1 answer
Post xml with axios nodejs
Javascript Node.js
1 vote332 views1 answer
What is the meanof using next in nodejs
Javascript Node.js
0 vote337 views1 answer
Node js request download file
Javascript Node.js
14 votes342 views6 answers
Node js connect to mongodb using mongoose
Javascript Node.js