/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 vote164 views1 answer
Dummy servers using nodejs
Javascript Node.js
0 vote173 views1 answer
Nodejs optimizing compuler try catch
Javascript Node.js
6 votes172 views1 answer
Nodejs create stream
Javascript Node.js
3 votes188 views1 answer
Nodejs express return image
Javascript Node.js
1 vote164 views1 answer
Is knex built into node js
Javascript Node.js
5 votes182 views2 answers
Socket emit to specific room using nodejs socket.io
Javascript Node.js
0 vote175 views1 answer
Run on localhost node js
Javascript Node.js
46 votes206 views4 answers
Node express params
Javascript Node.js
3 votes174 views1 answer
Node js console log object
Javascript Node.js
2 votes164 views1 answer
Get query string javascript nodejs
Javascript Node.js