const RabbitClient = require('rabbit-client');
 
const rabbitClient = new RabbitClient('amqp://localhost:5672', { json: true, appName: 'my-app' });

rabbitClient.getConnection();

const channel = await rabbitClient.getChannel();
 
await channel.sendToQueue('my-queue', { foo: bar });

rabbitClient.getChannel({
  onReconnect: async (channel) => {
    await channel.assertQueue('my-queue');
    await channel.purgeQueue('my-queue');
    await channel.prefetch(10);
    await channel.consume('my-queue', (msg, ch, data) => {
      console.log(data); // parsed json
      ch.ack(msg);
    })
  }
});