@involves/amqp-lib v0.1.62

@invovles/amqp-lib

Fork of @cloudamqp/amqp-client written in CommonJS.

Install

npm install @involves/amqp-lib --save

Example usage

Using AMQP in Node.js:

const AMQPClient = require('@involves/amqp-lib')

async function run() {
  try {
    const amqp = new AMQPClient('amqp://localhost')
    const conn = await amqp.connect()
    const ch = await conn.channel()
    const q = await ch.queue()
    const consumer = await q.subscribe({noAck: true}, async (msg) => {
      console.log(msg.bodyToString())
      await consumer.cancel()
    })
    await q.publish('Hello World', {deliveryMode: 2})
    await consumer.wait() // will block until consumer is canceled or throw an error if server closed channel/connection
    await conn.close()
  } catch (e) {
    console.error('ERROR', e)
    e.connection.close()
    setTimeout(run, 1000) // will try to reconnect in 1s
  }
}

run()

How to run the tests

At the terminal, just type the command:

make test